.github/workflows/lint.yml

@@ -1,10 +0,0 @@
-name: lint
-on:
-  push:
-    branches:
-      - main
-  pull_request:
-
-jobs:
-  lint:
-    uses: lnbits/lnbits/.github/workflows/lint.yml@dev

.github/workflows/release.yml

@@ -1,9 +1,10 @@
 on:
   push:
     tags:
-      - 'v[0-9]+.[0-9]+.[0-9]+'
+      - "v[0-9]+.[0-9]+.[0-9]+"
 
 jobs:
+
   release:
     runs-on: ubuntu-latest
     steps:
@@ -33,12 +34,12 @@ jobs:
       - name: Create pull request in extensions repo
         env:
           GH_TOKEN: ${{ secrets.EXT_GITHUB }}
-          repo_name: '${{ github.event.repository.name }}'
+          repo_name: "${{ github.event.repository.name }}"
-          tag: '${{ github.ref_name }}'
+          tag: "${{ github.ref_name }}"
-          branch: 'update-${{ github.event.repository.name }}-${{ github.ref_name }}'
+          branch: "update-${{ github.event.repository.name }}-${{ github.ref_name }}"
-          title: '[UPDATE] ${{ github.event.repository.name }} to ${{ github.ref_name }}'
+          title: "[UPDATE] ${{ github.event.repository.name }} to ${{ github.ref_name }}"
-          body: 'https://github.com/lnbits/${{ github.event.repository.name }}/releases/${{ github.ref_name }}'
+          body: "https://github.com/lnbits/${{ github.event.repository.name }}/releases/${{ github.ref_name }}"
-          archive: 'https://github.com/lnbits/${{ github.event.repository.name }}/archive/refs/tags/${{ github.ref_name }}.zip'
+          archive: "https://github.com/lnbits/${{ github.event.repository.name }}/archive/refs/tags/${{ github.ref_name }}.zip"
         run: |
           cd lnbits-extensions
           git checkout -b $branch

.gitignore

@@ -1,4 +1 @@
 __pycache__
-node_modules
-.mypy_cache
-.venv

.prettierrc

@@ -1,12 +0,0 @@
-{
-  "semi": false,
-  "arrowParens": "avoid",
-  "insertPragma": false,
-  "printWidth": 80,
-  "proseWrap": "preserve",
-  "singleQuote": true,
-  "trailingComma": "none",
-  "useTabs": false,
-  "bracketSameLine": false,
-  "bracketSpacing": false
-}

Makefile

@@ -1,47 +0,0 @@
-all: format check
-
-format: prettier black ruff
-
-check: mypy pyright checkblack checkruff checkprettier
-
-prettier:
-	uv run ./node_modules/.bin/prettier --write .
-pyright:
-	uv run ./node_modules/.bin/pyright
-
-mypy:
-	uv run mypy .
-
-black:
-	uv run black .
-
-ruff:
-	uv run ruff check . --fix
-
-checkruff:
-	uv run ruff check .
-
-checkprettier:
-	uv run ./node_modules/.bin/prettier --check .
-
-checkblack:
-	uv run black --check .
-
-checkeditorconfig:
-	editorconfig-checker
-
-test:
-	PYTHONUNBUFFERED=1 \
-	DEBUG=true \
-	uv run pytest
-install-pre-commit-hook:
-	@echo "Installing pre-commit hook to git"
-	@echo "Uninstall the hook with uv run pre-commit uninstall"
-	uv run pre-commit install
-
-pre-commit:
-	uv run pre-commit run --all-files
-
-
-checkbundle:
-	@echo "skipping checkbundle"

README.md

@@ -33,9 +33,9 @@ LNbits Split Payments extension allows for distributing payments across multiple
 
 IMPORTANT:
 
-- If you split to a LNURLp or LNaddress through the LNURLp extension make sure your recipients allow comments ! Split&Scrub add a comment in your transaction - and if it is not allowed, the split/scrub will not take place.
+- If you split to a LNURLp or LNaddress through the LNURLp extension make sure your receipients allow comments ! Split&Scrub add a comment in your transaction - and if it is not allowed, the split/scrub will not take place.
-- Make sure the LNURLp / LNaddress of the recipient has its min-sats set very low (e.g. 1 sat). If the wallet does not belong to you you can [check with a Decoder](https://lightningdecoder.com/), if that is the case already
+- Make sure the LNURLp / LNaddress of the receipient has its min-sats set very low (e.g. 1 sat). If the wallet does not belong to you you can [check with a Decoder](https://lightningdecoder.com/), if that is the case already
-- Yes, there is fees - internal and external! Updating your own wallets on your own instance will not cost any fees but sending to an external instance will. Please notice that you should therefore not split up to 100% if you send to a wallet that is external (leave 1-2% reserve for routing fees!). External fees are deducted from the individual payment percentage of the recipient
+- Yes, there is fees - internal and external! Updating your own wallets on your own instance will not cost any fees but sending to an external instance will. Please notice that you should therefore not split up to 100% if you send to a wallet that is external (leave 1-2% reserve for routing fees!). External fees are deducted from the individual payment percentage of the receipient
 
 <img width="1148" alt="Bildschirm­foto 2023-05-01 um 22 14 36" src="https://user-images.githubusercontent.com/63317640/235534056-49296aeb-7295-4b4e-9f57-914a677f5ad4.png">
 <img width="1402" alt="Bildschirm­foto 2023-05-01 um 22 17 52" src="https://user-images.githubusercontent.com/63317640/235534063-b2734654-7c1a-48a3-b48e-32798c232b49.png">

__init__.py

@@ -1,12 +1,15 @@
 import asyncio
+from typing import List
 
 from fastapi import APIRouter
-from loguru import logger
 
-from .crud import db
+from lnbits.db import Database
-from .tasks import wait_for_paid_invoices
+from lnbits.helpers import template_renderer
-from .views import splitpayments_generic_router
+from lnbits.tasks import catch_everything_and_restart
-from .views_api import splitpayments_api_router
+
+db = Database("ext_splitpayments")
+
+scheduled_tasks: List[asyncio.Task] = []
 
 splitpayments_static_files = [
     {
@@ -17,31 +20,18 @@ splitpayments_static_files = [
 splitpayments_ext: APIRouter = APIRouter(
     prefix="/splitpayments", tags=["splitpayments"]
 )
-splitpayments_ext.include_router(splitpayments_generic_router)
-splitpayments_ext.include_router(splitpayments_api_router)
-
-scheduled_tasks: list[asyncio.Task] = []
 
 
-def splitpayments_stop():
+def splitpayments_renderer():
-    for task in scheduled_tasks:
+    return template_renderer(["splitpayments/templates"])
-        try:
+
-            task.cancel()
+
-        except Exception as ex:
+from .tasks import wait_for_paid_invoices
-            logger.warning(ex)
+from .views import *  # noqa: F401,F403
+from .views_api import *  # noqa: F401,F403
 
 
 def splitpayments_start():
-    from lnbits.tasks import create_permanent_unique_task
+    loop = asyncio.get_event_loop()
-
+    task = loop.create_task(catch_everything_and_restart(wait_for_paid_invoices))
-    task = create_permanent_unique_task("ext_splitpayments", wait_for_paid_invoices)
     scheduled_tasks.append(task)
-
-
-__all__ = [
-    "db",
-    "splitpayments_ext",
-    "splitpayments_start",
-    "splitpayments_static_files",
-    "splitpayments_stop",
-]

config.json

@@ -2,57 +2,6 @@
   "name": "Split Payments",
   "short_description": "Split incoming payments across wallets",
   "tile": "/splitpayments/static/image/split-payments.png",
-  "version": "1.1.0",
+  "contributors": ["fiatjaf", "cryptograffiti"],
-  "min_lnbits_version": "1.3.0",
+  "min_lnbits_version": "0.11.0"
-  "contributors": [
-    {
-      "name": "cryptograffiti",
-      "uri": "https://github.com/cryptograffiti",
-      "role": "Idea/Sponsor"
-    },
-    {
-      "name": "fiatjaf",
-      "uri": "https://github.com/fiatjaf",
-      "role": "Developer"
-    },
-    {
-      "name": "dni",
-      "uri": "https://github.com/dni",
-      "role": "Developer"
-    },
-    {
-      "name": "talvasconcelos",
-      "uri": "https://github.com/talvasconcelos",
-      "role": "Developer"
-    },
-    {
-      "name": "prusnak",
-      "uri": "https://github.com/prusnak",
-      "role": "Developer"
-    },
-    {
-      "name": "arbadacarbaYK",
-      "uri": "https://github.com/arbadacarbaYK",
-      "role": "Developer"
-    },
-    {
-      "name": "arcbtc",
-      "uri": "https://github.com/arcbtc",
-      "role": "Developer"
-    }
-  ],
-  "images": [
-    {
-      "uri": "https://raw.githubusercontent.com/lnbits/splitpayments/main/static/image/1.png"
-    },
-    {
-      "uri": "https://raw.githubusercontent.com/lnbits/splitpayments/main/static/image/2.png"
-    },
-    {
-      "uri": "https://raw.githubusercontent.com/lnbits/splitpayments/main/static/image/3.png"
-    }
-  ],
-  "description_md": "https://raw.githubusercontent.com/lnbits/splitpayments/main/description.md",
-  "terms_and_conditions_md": "https://raw.githubusercontent.com/lnbits/splitpayments/main/toc.md",
-  "license": "MIT"
 }

crud.py

@@ -1,23 +1,35 @@
-from lnbits.db import Database
+from typing import List
 
+from lnbits.helpers import urlsafe_short_hash
+
+from . import db
 from .models import Target
 
-db = Database("ext_splitpayments")
 
-
+async def get_targets(source_wallet: str) -> List[Target]:
-async def get_targets(source_wallet: str) -> list[Target]:
+    rows = await db.fetchall(
-    return await db.fetchall(
+        "SELECT * FROM splitpayments.targets WHERE source = ?", (source_wallet,)
-        "SELECT * FROM splitpayments.targets WHERE source = :source_wallet",
-        {"source_wallet": source_wallet},
-        Target,
     )
+    return [Target(**row) for row in rows]
 
 
-async def set_targets(source_wallet: str, targets: list[Target]):
+async def set_targets(source_wallet: str, targets: List[Target]):
     async with db.connect() as conn:
         await conn.execute(
-            "DELETE FROM splitpayments.targets WHERE source = :source_wallet",
+            "DELETE FROM splitpayments.targets WHERE source = ?", (source_wallet,)
-            {"source_wallet": source_wallet},
         )
         for target in targets:
-            await conn.insert("splitpayments.targets", target)
+            await conn.execute(
+                """
+                INSERT INTO splitpayments.targets
+                  (id, source, wallet, percent, alias)
+                VALUES (?, ?, ?, ?, ?)
+            """,
+                (
+                    urlsafe_short_hash(),
+                    source_wallet,
+                    target.wallet,
+                    target.percent,
+                    target.alias,
+                ),
+            )

description.md

@@ -1,16 +0,0 @@
-Split Payments across multiple wallets/lnaddresses/lnurlps seamlessly!
-Once configured, it continuously splits your payments across different wallets.
-
-Usage:
-
-- Enable the Extension: Start by enabling the Split Payments extension.
-- Select the Source Wallet: Identify and select the wallet that will receive and subsequently distribute the payments.
-- Add Wallet Information for Payment Splitting: Enter the details of the wallets where the payments will be split. This could include LNURLp, LNaddress, wallet ID, or an invoice key from a different wallet. Wallet details can be found under the API Info section on each wallet's page. Optionally, assign an alias to each wallet for easier identification.
-- Set Distribution Percentages: Specify the percentage of each payment that each wallet should receive. Ensure the total distribution does not exceed 100%.
-- Save Your Settings: After adding or deleting wallet information, click “SAVE TARGETS” to activate the payment splits.
-
-Note:
-You can distribute payments to multiple wallets as long as their combined percentage is at or below 100%. Distribution can only total exactly 100% if all target wallets are internal.
-
-Automatic Payment Splitting:
-When the source wallet receives a payment, the extension automatically allocates the specified percentages to each designated wallet.

manifest.json

@@ -2,7 +2,7 @@
   "repos": [
     {
       "id": "splitpayments",
-      "organisation": "PatMulligan",
+      "organisation": "lnbits",
       "repository": "splitpayments"
     }
   ]

migrations.py

@@ -1,8 +1,7 @@
-from lnbits.db import Connection
 from lnbits.helpers import urlsafe_short_hash
 
 
-async def m001_initial(db: Connection):
+async def m001_initial(db):
     """
     Initial split payment table.
     """
@@ -20,12 +19,11 @@ async def m001_initial(db: Connection):
     )
 
 
-async def m002_float_percent(db: Connection):
+async def m002_float_percent(db):
     """
-    alter percent to be float.
+    Add float percent and migrates the existing data.
     """
-    await db.execute("ALTER TABLE splitpayments.targets RENAME TO splitpayments_m001")
+    await db.execute("ALTER TABLE splitpayments.targets RENAME TO splitpayments_old")
-
     await db.execute(
         """
         CREATE TABLE splitpayments.targets (
@@ -38,9 +36,11 @@ async def m002_float_percent(db: Connection):
         );
     """
     )
-    result = await db.execute("SELECT * FROM splitpayments.splitpayments_m001")
+
-    rows = result.mappings().all()
+    for row in [
-    for row in rows:
+        list(row)
+        for row in await db.fetchall("SELECT * FROM splitpayments.splitpayments_old")
+    ]:
         await db.execute(
             """
             INSERT INTO splitpayments.targets (
@@ -49,25 +49,19 @@ async def m002_float_percent(db: Connection):
                 percent,
                 alias
             )
-            VALUES (:wallet, :source, :percent, :alias)
+            VALUES (?, ?, ?, ?)
             """,
-            {
+            (row[0], row[1], row[2], row[3]),
-                "wallet": row["wallet"],
-                "source": row["source"],
-                "percent": row["percent"],
-                "alias": row["alias"],
-            },
         )
 
-    await db.execute("DROP TABLE splitpayments.splitpayments_m001")
+    await db.execute("DROP TABLE splitpayments.splitpayments_old")
 
 
-async def m003_add_id_and_tag(db: Connection):
+async def m003_add_id_and_tag(db):
     """
-    Add id, tag and migrates the existing data.
+    Add float percent and migrates the existing data.
     """
-    await db.execute("ALTER TABLE splitpayments.targets RENAME TO splitpayments_m002")
+    await db.execute("ALTER TABLE splitpayments.targets RENAME TO splitpayments_old")
-
     await db.execute(
         """
         CREATE TABLE splitpayments.targets (
@@ -82,9 +76,11 @@ async def m003_add_id_and_tag(db: Connection):
         );
     """
     )
-    result = await db.execute("SELECT * FROM splitpayments.splitpayments_m002")
+
-    rows = result.mappings().all()
+    for row in [
-    for row in rows:
+        list(row)
+        for row in await db.fetchall("SELECT * FROM splitpayments.splitpayments_old")
+    ]:
         await db.execute(
             """
             INSERT INTO splitpayments.targets (
@@ -95,31 +91,23 @@ async def m003_add_id_and_tag(db: Connection):
                 tag,
                 alias
             )
-            VALUES (:id, :wallet, :source, :percent, :tag, :alias)
+            VALUES (?, ?, ?, ?, ?, ?)
             """,
-            {
+            (urlsafe_short_hash(), row[0], row[1], row[2], "", row[3]),
-                "id": urlsafe_short_hash(),
-                "wallet": row["wallet"],
-                "source": row["source"],
-                "percent": row["percent"],
-                "tag": row["tag"],
-                "alias": row["alias"],
-            },
         )
 
-    await db.execute("DROP TABLE splitpayments.splitpayments_m002")
+    await db.execute("DROP TABLE splitpayments.splitpayments_old")
 
 
-async def m004_remove_tag(db: Connection):
+async def m004_remove_tag(db):
     """
     This removes tag
     """
     keys = "id,wallet,source,percent,alias"
     new_db = "splitpayments.targets"
-    old_db = "splitpayments.targets_m003"
+    old_db = "splitpayments.targets_old"
-
-    await db.execute(f"ALTER TABLE {new_db} RENAME TO targets_m003")
 
+    await db.execute(f"ALTER TABLE {new_db} RENAME TO targets_old")
     await db.execute(
         f"""
         CREATE TABLE {new_db} (

models.py

@@ -1,13 +1,19 @@
+from sqlite3 import Row
+from typing import List, Optional
+
 from fastapi import Query
 from pydantic import BaseModel
 
 
 class Target(BaseModel):
-    id: str
     wallet: str
     source: str
     percent: float
-    alias: str | None = None
+    alias: Optional[str]
+
+    @classmethod
+    def from_row(cls, row: Row):
+        return cls(**dict(row))
 
 
 class TargetPut(BaseModel):
@@ -17,4 +23,4 @@ class TargetPut(BaseModel):
 
 
 class TargetPutList(BaseModel):
-    targets: list[TargetPut]
+    targets: List[TargetPut]

package-lock.json

@@ -1,59 +0,0 @@
-{
-  "name": "splitpayments",
-  "version": "1.0.0",
-  "lockfileVersion": 3,
-  "requires": true,
-  "packages": {
-    "": {
-      "name": "splitpayments",
-      "version": "1.0.0",
-      "license": "ISC",
-      "dependencies": {
-        "prettier": "^3.2.5",
-        "pyright": "^1.1.358"
-      }
-    },
-    "node_modules/fsevents": {
-      "version": "2.3.3",
-      "resolved": "https://registry.npmjs.org/fsevents/-/fsevents-2.3.3.tgz",
-      "integrity": "sha512-5xoDfX+fL7faATnagmWPpbFtwh/R77WmMMqqHGS65C3vvB0YHrgF+B1YmZ3441tMj5n63k0212XNoJwzlhffQw==",
-      "hasInstallScript": true,
-      "optional": true,
-      "os": [
-        "darwin"
-      ],
-      "engines": {
-        "node": "^8.16.0 || ^10.6.0 || >=11.0.0"
-      }
-    },
-    "node_modules/prettier": {
-      "version": "3.3.3",
-      "resolved": "https://registry.npmjs.org/prettier/-/prettier-3.3.3.tgz",
-      "integrity": "sha512-i2tDNA0O5IrMO757lfrdQZCc2jPNDVntV0m/+4whiDfWaTKfMNgR7Qz0NAeGz/nRqF4m5/6CLzbP4/liHt12Ew==",
-      "bin": {
-        "prettier": "bin/prettier.cjs"
-      },
-      "engines": {
-        "node": ">=14"
-      },
-      "funding": {
-        "url": "https://github.com/prettier/prettier?sponsor=1"
-      }
-    },
-    "node_modules/pyright": {
-      "version": "1.1.374",
-      "resolved": "https://registry.npmjs.org/pyright/-/pyright-1.1.374.tgz",
-      "integrity": "sha512-ISbC1YnYDYrEatoKKjfaA5uFIp0ddC/xw9aSlN/EkmwupXUMVn41Jl+G6wHEjRhC+n4abHZeGpEvxCUus/K9dA==",
-      "bin": {
-        "pyright": "index.js",
-        "pyright-langserver": "langserver.index.js"
-      },
-      "engines": {
-        "node": ">=14.0.0"
-      },
-      "optionalDependencies": {
-        "fsevents": "~2.3.3"
-      }
-    }
-  }
-}

package.json

@@ -1,15 +0,0 @@
-{
-  "name": "splitpayments",
-  "version": "1.0.0",
-  "description": "",
-  "main": "index.js",
-  "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
-  },
-  "author": "",
-  "license": "ISC",
-  "dependencies": {
-    "prettier": "^3.2.5",
-    "pyright": "^1.1.358"
-  }
-}

pyproject.toml

@@ -1,92 +0,0 @@
-[project]
-name = "splitpayments"
-version = "1.1.1"
-requires-python = ">=3.10,<3.13"
-description = "Send incoming payments to different targets"
-authors = [{name = "benarc"}, {name = "dni"}, {name = "alan"}]
-urls = { Homepage = "https://lnbits.com", Repository = "https://github.com/lnbits/splitpayments" }
-
-dependencies = [ "lnbits>1" ]
-
-[tool.poetry]
-package-mode = false
-
-[tool.uv]
-dev-dependencies = [
-    "black",
-    "pytest-asyncio",
-    "pytest",
-    "mypy==1.17.1",
-    "pre-commit",
-    "ruff",
-    "pytest-md",
-]
-
-[tool.mypy]
-exclude = "(nostr/*)"
-plugins = ["pydantic.mypy"]
-
-[tool.pydantic-mypy]
-init_forbid_extra = true
-init_typed = true
-warn_required_dynamic_aliases = true
-warn_untyped_fields = true
-
-[tool.pytest.ini_options]
-log_cli = false
-testpaths = [
-  "tests"
-]
-
-[tool.black]
-line-length = 88
-
-[tool.ruff]
-# Same as Black. + 10% rule of black
-line-length = 88
-exclude = [
-    "nostr",
-]
-
-[tool.ruff.lint]
-# Enable:
-# F - pyflakes
-# E - pycodestyle errors
-# W - pycodestyle warnings
-# I - isort
-# A - flake8-builtins
-# C - mccabe
-# N - naming
-# UP - pyupgrade
-# RUF - ruff
-# B - bugbear
-select = ["F", "E", "W", "I", "A", "C", "N", "UP", "RUF", "B"]
-ignore = ["C901"]
-
-# Allow autofix for all enabled rules (when `--fix`) is provided.
-fixable = ["ALL"]
-unfixable = []
-
-# Allow unused variables when underscore-prefixed.
-dummy-variable-rgx = "^(_+|(_+[a-zA-Z0-9_]*[a-zA-Z0-9]+?))$"
-
-# needed for pydantic
-[tool.ruff.lint.pep8-naming]
-classmethod-decorators = [
-    "validator",
-    "root_validator",
-]
-
-# Ignore unused imports in __init__.py files.
-# [tool.ruff.lint.extend-per-file-ignores]
-# "__init__.py" = ["F401", "F403"]
-
-# [tool.ruff.lint.mccabe]
-# max-complexity = 10
-
-[tool.ruff.lint.flake8-bugbear]
-# Allow default arguments like, e.g., `data: List[str] = fastapi.Query(None)`.
-extend-immutable-calls = [
-    "fastapi.Depends",
-    "fastapi.Query",
-]

static/js/index.js

@@ -1,3 +1,7 @@
+/* globals Quasar, Vue, _, VueQrcode, windowMixin, LNbits, LOCALE */
+
+Vue.component(VueQrcode.name, VueQrcode)
+
 function hashTargets(targets) {
   return targets
     .filter(isTargetComplete)
@@ -13,14 +17,9 @@ function isTargetComplete(target) {
   )
 }
 
-window.app = Vue.createApp({
+new Vue({
   el: '#vue',
   mixins: [windowMixin],
-  watch: {
-    selectedWallet() {
-      this.getTargets()
-    }
-  },
   data() {
     return {
       selectedWallet: null,
@@ -39,7 +38,7 @@ window.app = Vue.createApp({
         return this.deleteTargets()
       }
       this.targets.splice(index, 1)
-      Quasar.Notify.create({
+      this.$q.notify({
         message: 'Removed item. You must click to save manually.',
         timeout: 500
       })
@@ -51,11 +50,8 @@ window.app = Vue.createApp({
           '/splitpayments/api/v1/targets',
           this.selectedWallet.adminkey
         )
-        .then(res => {
+        .then(response => {
-          this.targets = res.data.map(t => ({
+          this.targets = response.data
-            ...t,
-            targetChoice: t.targetChoice || 'wallet'
-          }))
         })
         .catch(err => {
           LNbits.utils.notifyApiError(err)
@@ -66,30 +62,20 @@ window.app = Vue.createApp({
       this.getTargets()
     },
     addTarget() {
-      this.targets.push({
+      this.targets.push({source: this.selectedWallet})
-        source: this.selectedWallet,
-        targetChoice: 'wallet'
-      })
     },
     saveTargets() {
-      const payload = this.targets
-        .filter(t => t.wallet && String(t.wallet).trim() !== '')
-        .map(({alias, percent, wallet}) => ({
-          alias,
-          percent: Number(percent) || 0,
-          wallet
-        }))
       LNbits.api
         .request(
           'PUT',
           '/splitpayments/api/v1/targets',
           this.selectedWallet.adminkey,
           {
-            targets: payload
+            targets: this.targets
           }
         )
         .then(response => {
-          Quasar.Notify.create({
+          this.$q.notify({
             message: 'Split payments targets set.',
             timeout: 700
           })
@@ -110,7 +96,7 @@ window.app = Vue.createApp({
               this.selectedWallet.adminkey
             )
             .then(response => {
-              Quasar.Notify.create({
+              this.$q.notify({
                 message: 'Split payments targets deleted.',
                 timeout: 700
               })
@@ -123,5 +109,6 @@ window.app = Vue.createApp({
   },
   created() {
     this.selectedWallet = this.g.user.wallets[0]
+    this.getTargets()
   }
 })

tasks.py

@@ -1,25 +1,25 @@
 import asyncio
+import json
 from math import floor
+from typing import Optional
 
-import bolt11
+import httpx
-from lnbits.core.crud import get_standalone_payment
-from lnbits.core.crud.wallets import get_wallet_for_key
-from lnbits.core.models import Payment
-from lnbits.core.services import (
-    create_invoice,
-    fee_reserve,
-    get_pr_from_lnurl,
-    pay_invoice,
-)
-from lnbits.tasks import register_invoice_listener
 from loguru import logger
 
+from lnbits import bolt11
+from lnbits.core.crud import get_standalone_payment
+from lnbits.core.models import Payment
+from lnbits.core.services import create_invoice, fee_reserve, pay_invoice
+from lnbits.helpers import get_current_extension_name
+from lnbits.tasks import register_invoice_listener
+
 from .crud import get_targets
 
 
 async def wait_for_paid_invoices():
     invoice_queue = asyncio.Queue()
-    register_invoice_listener(invoice_queue, "ext_splitpayments_invoice_listener")
+    register_invoice_listener(invoice_queue, get_current_extension_name())
+
     while True:
         payment = await invoice_queue.get()
         await on_invoice_paid(payment)
@@ -45,76 +45,83 @@ async def on_invoice_paid(payment: Payment) -> None:
     logger.trace(f"splitpayments: performing split payments to {len(targets)} targets")
 
     for target in targets:
+
         if target.percent > 0:
+
             amount_msat = int(payment.amount * target.percent / 100)
             memo = (
-                f"Split payment: {target.percent}% "
+                f"Split payment: {target.percent}% for {target.alias or target.wallet}"
-                f"for {target.alias or target.wallet}"
-                f";{payment.memo};{payment.payment_hash}"
             )
 
-            if "@" in target.wallet or "LNURL" in target.wallet:
+            if target.wallet.find("@") >= 0 or target.wallet.find("LNURL") >= 0:
                 safe_amount_msat = amount_msat - fee_reserve(amount_msat)
                 payment_request = await get_lnurl_invoice(
                     target.wallet, payment.wallet_id, safe_amount_msat, memo
                 )
             else:
-                wallet = await get_wallet_for_key(target.wallet)
+                _, payment_request = await create_invoice(
-                if wallet is not None:
-                    target.wallet = wallet.id
-                new_payment = await create_invoice(
                     wallet_id=target.wallet,
                     amount=int(amount_msat / 1000),
                     internal=True,
                     memo=memo,
                 )
-                payment_request = new_payment.bolt11
 
-            extra = {**payment.extra, "splitted": True}
+            extra = {**payment.extra, "tag": "splitpayments", "splitted": True}
 
             if payment_request:
-                task = asyncio.create_task(
+                await pay_invoice(
-                    pay_invoice_in_background(
                     payment_request=payment_request,
                     wallet_id=payment.wallet_id,
                     description=memo,
                     extra=extra,
                 )
-                )
-                task.add_done_callback(lambda fut: logger.success(fut.result()))
-
-
-async def pay_invoice_in_background(payment_request, wallet_id, description, extra):
-    try:
-        await pay_invoice(
-            payment_request=payment_request,
-            wallet_id=wallet_id,
-            description=description,
-            extra=extra,
-        )
-        return f"Splitpayments: paid invoice for {description}"
-    except Exception as e:
-        logger.error(f"Failed to pay invoice: {e}")
 
 
 async def get_lnurl_invoice(
-    payoraddress: str, wallet_id: str, amount_msat: int, memo: str
+    payoraddress, wallet_id, amount_msat, memo
-) -> str | None:
+) -> Optional[str]:
 
+    from lnbits.core.views.api import api_lnurlscan
+
+    data = await api_lnurlscan(payoraddress)
     rounded_amount = floor(amount_msat / 1000) * 1000
 
+    async with httpx.AsyncClient() as client:
         try:
-        payment_request = await get_pr_from_lnurl(payoraddress, rounded_amount, memo)
+            r = await client.get(
-    except Exception as e:
+                data["callback"],
-        logger.error(f"Error getting LNURL invoice: {e!s}")
+                params={"amount": rounded_amount, "comment": memo},
+                timeout=40,
+            )
+            if r.is_error:
+                raise httpx.ConnectError("issue with scrub callback")
+            r.raise_for_status()
+        except (httpx.ConnectError, httpx.RequestError):
+            logger.error(
+                f"splitting LNURL failed: Failed to connect to {data['callback']}."
+            )
+            return None
+        except Exception as exc:
+            logger.error(f"splitting LNURL failed: {str(exc)}.")
             return None
 
-    invoice = bolt11.decode(payment_request)
+    params = json.loads(r.text)
+    if params.get("status") == "ERROR":
+        logger.error(f"{data['callback']} said: '{params.get('reason', '')}'")
+        return None
+
+    invoice = bolt11.decode(params["pr"])
 
     lnurlp_payment = await get_standalone_payment(invoice.payment_hash)
 
     if lnurlp_payment and lnurlp_payment.wallet_id == wallet_id:
-        logger.error("split failed. cannot split payments to yourself via LNURL.")
+        logger.error(f"split failed. cannot split payments to yourself via LNURL.")
         return None
 
-    return payment_request
+    if invoice.amount_msat != rounded_amount:
+        logger.error(
+            f"{data['callback']} returned an invalid invoice. Expected {amount_msat} msat, got {invoice.amount_msat}."
+        )
+        return None
+
+    return params["pr"]

templates/splitpayments/index.html

@@ -9,9 +9,10 @@
             filled
             dense
             :options="g.user.wallets"
-            v-model="selectedWallet"
+            :value="selectedWallet"
             label="Source Wallet:"
             option-label="name"
+            @input="changedWallet"
           >
           </q-select>
         </q-form>
@@ -38,30 +39,12 @@
               :hint="t === targets.length - 1 ? 'A name to identify this target wallet locally.' : undefined"
               style="width: 150px"
             ></q-input>
-            <div class="column q-mt-none">
+
-              <div class="col">
-                <q-radio
-                  class="float-left"
-                  v-model="target.targetChoice"
-                  val="wallet"
-                  label="wallet"
-                ></q-radio>
-              </div>
-              <div class="col">
-                <q-radio
-                  class="float-left"
-                  v-model="target.targetChoice"
-                  val="lnurl"
-                  label="lnurl"
-                ></q-radio>
-              </div>
-            </div>
             <q-input
-              v-if="target.targetChoice === 'lnurl'"
               dense
               v-model.trim="target.wallet"
               label="Target"
-              hint="LNURLp or Lightning Address."
+              hint="A wallet ID, invoice key, LNURLp or Lightning Address."
               option-label="name"
               style="width: 500px"
               new-value-mode="add-unique"
@@ -69,19 +52,6 @@
               input-debounce="0"
               emit-value
             ></q-input>
-            <q-select
-              v-if="target.targetChoice === 'wallet'"
-              class="q-pr-md q-pt-sm"
-              filled
-              dense
-              style="width: 500px"
-              v-model="target.wallet"
-              :options="g.user.walletOptions"
-              emit-value
-              map-options
-              label="Receive wallet *"
-            >
-            </q-select>
 
             <q-input
               style="width: 150px"

tests/test_init.py

@@ -1,11 +0,0 @@
-import pytest
-from fastapi import APIRouter
-
-from .. import splitpayments_ext
-
-
-# just import router and add it to a test router
-@pytest.mark.asyncio
-async def test_router():
-    router = APIRouter()
-    router.include_router(splitpayments_ext)

toc.md

@@ -1,29 +0,0 @@
-# Terms and Conditions for LNbits Extension
-
-## 1. Acceptance of Terms
-
-By installing and using the LNbits extension ("Extension"), you agree to be bound by these terms and conditions ("Terms"). If you do not agree to these Terms, do not use the Extension.
-
-## 2. License
-
-The Extension is free and open-source software, released under [specify the FOSS license here, e.g., GPL-3.0, MIT, etc.]. You are permitted to use, copy, modify, and distribute the Extension under the terms of that license.
-
-## 3. No Warranty
-
-The Extension is provided "as is" and with all faults, and the developer expressly disclaims all warranties of any kind, whether express, implied, statutory, or otherwise, including but not limited to warranties of merchantability, fitness for a particular purpose, non-infringement, and any warranties arising out of course of dealing or usage of trade. No advice or information, whether oral or written, obtained from the developer or elsewhere will create any warranty not expressly stated in this Terms.
-
-## 4. Limitation of Liability
-
-In no event will the developer be liable to you or any third party for any direct, indirect, incidental, special, consequential, or punitive damages, including lost profit, lost revenue, loss of data, or other damages arising out of or in connection with your use of the Extension, even if the developer has been advised of the possibility of such damages. The foregoing limitation of liability shall apply to the fullest extent permitted by law in the applicable jurisdiction.
-
-## 5. Modification of Terms
-
-The developer reserves the right to modify these Terms at any time. You are advised to review these Terms periodically for any changes. Changes to these Terms are effective when they are posted on the appropriate location within or associated with the Extension.
-
-## 6. General Provisions
-
-If any provision of these Terms is held to be invalid or unenforceable, that provision will be enforced to the maximum extent permissible, and the other provisions of these Terms will remain in full force and effect. These Terms constitute the entire agreement between you and the developer regarding the use of the Extension.
-
-## 7. Contact Information
-
-If you have any questions about these Terms, please contact the developer at [developer's contact information].

views.py

@@ -1,18 +1,17 @@
-from fastapi import APIRouter, Depends, Request
+from fastapi import Depends, Request
-from fastapi.responses import HTMLResponse
+from fastapi.templating import Jinja2Templates
+from starlette.responses import HTMLResponse
+
 from lnbits.core.models import User
 from lnbits.decorators import check_user_exists
-from lnbits.helpers import template_renderer
 
-splitpayments_generic_router = APIRouter()
+from . import splitpayments_ext, splitpayments_renderer
+
+templates = Jinja2Templates(directory="templates")
 
 
-def splitpayments_renderer():
+@splitpayments_ext.get("/", response_class=HTMLResponse)
-    return template_renderer(["splitpayments/templates"])
-
-
-@splitpayments_generic_router.get("/", response_class=HTMLResponse)
 async def index(request: Request, user: User = Depends(check_user_exists)):
     return splitpayments_renderer().TemplateResponse(
-        "splitpayments/index.html", {"request": request, "user": user.json()}
+        "splitpayments/index.html", {"request": request, "user": user.dict()}
     )

views_api.py

@@ -1,39 +1,39 @@
 from http import HTTPStatus
+from typing import List
 
-from fastapi import APIRouter, Depends, HTTPException
+from fastapi import Depends
-from lnbits.core.crud import get_wallet, get_wallet_for_key
-from lnbits.core.models import WalletTypeInfo
-from lnbits.decorators import require_admin_key
-from lnbits.helpers import urlsafe_short_hash
 from loguru import logger
+from starlette.exceptions import HTTPException
 
+from lnbits.core.crud import get_wallet, get_wallet_for_key
+from lnbits.decorators import WalletTypeInfo, check_admin, require_admin_key
+
+from . import scheduled_tasks, splitpayments_ext
 from .crud import get_targets, set_targets
 from .models import Target, TargetPutList
 
-splitpayments_api_router = APIRouter()
 
-
+@splitpayments_ext.get("/api/v1/targets")
-@splitpayments_api_router.get("/api/v1/targets")
 async def api_targets_get(
     wallet: WalletTypeInfo = Depends(require_admin_key),
-) -> list[Target]:
+) -> List[Target]:
     targets = await get_targets(wallet.wallet.id)
     return targets or []
 
 
-@splitpayments_api_router.put("/api/v1/targets", status_code=HTTPStatus.OK)
+@splitpayments_ext.put("/api/v1/targets", status_code=HTTPStatus.OK)
 async def api_targets_set(
     target_put: TargetPutList,
     source_wallet: WalletTypeInfo = Depends(require_admin_key),
 ) -> None:
     try:
-        targets: list[Target] = []
+        targets: List[Target] = []
         for entry in target_put.targets:
 
             if entry.wallet.find("@") < 0 and entry.wallet.find("LNURL") < 0:
                 wallet = await get_wallet(entry.wallet)
                 if not wallet:
-                    wallet = await get_wallet_for_key(entry.wallet)
+                    wallet = await get_wallet_for_key(entry.wallet, "invoice")
                     if not wallet:
                         raise HTTPException(
                             status_code=HTTPStatus.BAD_REQUEST,
@@ -42,8 +42,7 @@ async def api_targets_set(
 
                 if wallet.id == source_wallet.wallet.id:
                     raise HTTPException(
-                        status_code=HTTPStatus.BAD_REQUEST,
+                        status_code=HTTPStatus.BAD_REQUEST, detail="Can't split to itself."
-                        detail="Can't split to itself.",
                     )
 
             if entry.percent <= 0:
@@ -54,7 +53,6 @@ async def api_targets_set(
 
             targets.append(
                 Target(
-                    id=urlsafe_short_hash(),
                     wallet=entry.wallet,
                     source=source_wallet.wallet.id,
                     percent=entry.percent,
@@ -75,11 +73,24 @@ async def api_targets_set(
         raise HTTPException(
             status_code=HTTPStatus.INTERNAL_SERVER_ERROR,
             detail="Cannot set targets.",
-        ) from ex
+        )
 
 
-@splitpayments_api_router.delete("/api/v1/targets", status_code=HTTPStatus.OK)
+@splitpayments_ext.delete("/api/v1/targets", status_code=HTTPStatus.OK)
 async def api_targets_delete(
     source_wallet: WalletTypeInfo = Depends(require_admin_key),
 ) -> None:
     await set_targets(source_wallet.wallet.id, [])
+
+
+# deinit extension invoice listener
+@splitpayments_ext.delete(
+    "/api/v1", status_code=HTTPStatus.OK, dependencies=[Depends(check_admin)]
+)
+async def api_stop():
+    for t in scheduled_tasks:
+        try:
+            t.cancel()
+        except Exception as ex:
+            logger.warning(ex)
+    return {"success": True}