- {JSON.stringify(record, null, 2)}
-
- -
- {useMediaQuery((theme: Theme) => theme.breakpoints.down("md")) ? (
-
{record.blobs.length} blobs
; -} -function UserProfile() { - const record = useRecordContext(); - if (!record.profile) return null; - return ( --
- {useMediaQuery((theme: Theme) => theme.breakpoints.down("md")) ? (
-
- It adds a small floating button on the side of the window that users - can use to create Nostr accuonts or connect to their NIP-46 bunkers.
This tool is opensource, get the code from the project's page.
You don't know what Nostr is? - Learn more.
`,v(e,"class","text-center text-lg"),v(r,"class","text-base leading-5")},m(o,i){q(o,e,i),q(o,n,i),q(o,r,i)},p:L,i:L,o:L,d(o){o&&(R(e),R(n),R(r))}}}function Kc(t){let e,n,r,o,i,s,c=new URL(t[15]).host+"",a,l,f,u,g,h,b,d,p,y;return{c(){e=N("div"),n=N("div"),n.textContent="An action requires your confirmation",r=$(),o=N("div"),i=j("Now you a new window will bring you to "),s=N("strong"),a=j(c),l=j(" where you can approve the current action. If nothing happens check that if your browser is blocking popups, pleaase."),f=N("br"),u=j(` - After that you will be returned to this page.`),g=$(),h=N("button"),b=j("Confirm action »"),v(n,"class","text-center text-lg"),v(o,"class","mt-4 text-center text-sm leading-4"),v(h,"class",d="mt-4 block w-full cursor-pointer rounded border-0 px-2 py-1 text-lg text-white disabled:cursor-default disabled:bg-neutral-400 disabled:text-neutral-200 bg-"+t[0]+"-900 hover:bg-"+t[0]+"-950"),v(e,"class","m-auto w-full")},m(w,E){q(w,e,E),k(e,n),k(e,r),k(e,o),k(o,i),k(o,s),k(s,a),k(o,l),k(o,f),k(o,u),k(e,g),k(e,h),k(h,b),p||(y=J(h,"click",t[48]),p=!0)},p(w,E){E[0]&32768&&c!==(c=new URL(w[15]).host+"")&&Pe(a,c),E[0]&1&&d!==(d="mt-4 block w-full cursor-pointer rounded border-0 px-2 py-1 text-lg text-white disabled:cursor-default disabled:bg-neutral-400 disabled:text-neutral-200 bg-"+w[0]+"-900 hover:bg-"+w[0]+"-950")&&v(h,"class",d)},i:L,o:L,d(w){w&&R(e),p=!1,y()}}}function Dc(t){let e,n,r,o,i,s,c=new URL(t[14]).host+"",a,l,f,u,g,h,b,d,p,y;return{c(){e=N("div"),n=N("div"),n.textContent="Login into a Nostr account",r=$(),o=N("div"),i=j("Now you a new window will bring you to "),s=N("strong"),a=j(c),l=j(" where you can login and approve the permissions. If nothing happens check that if your browser is blocking popups, pleaase."),f=N("br"),u=j(` - After that you will be returned to this page.`),g=$(),h=N("button"),b=j("Login now »"),v(n,"class","text-center text-lg"),v(o,"class","mt-4 text-center text-sm leading-4"),v(h,"class",d="mt-4 block w-full cursor-pointer rounded border-0 px-2 py-1 text-lg text-white disabled:cursor-default disabled:bg-neutral-400 disabled:text-neutral-200 bg-"+t[0]+"-900 hover:bg-"+t[0]+"-950"),v(e,"class","m-auto w-full")},m(w,E){q(w,e,E),k(e,n),k(e,r),k(e,o),k(o,i),k(o,s),k(s,a),k(o,l),k(o,f),k(o,u),k(e,g),k(e,h),k(h,b),p||(y=J(h,"click",t[47]),p=!0)},p(w,E){E[0]&16384&&c!==(c=new URL(w[14]).host+"")&&Pe(a,c),E[0]&1&&d!==(d="mt-4 block w-full cursor-pointer rounded border-0 px-2 py-1 text-lg text-white disabled:cursor-default disabled:bg-neutral-400 disabled:text-neutral-200 bg-"+w[0]+"-900 hover:bg-"+w[0]+"-950")&&v(h,"class",d)},i:L,o:L,d(w){w&&R(e),p=!1,y()}}}function Wc(t){let e,n,r,o,i,s,c=new URL(t[13]).host+"",a,l,f,u,g,h,b,d,p,y;return{c(){e=N("div"),n=N("div"),n.textContent="Create a Nostr account",r=$(),o=N("div"),i=j("Now you a new window will bring you to "),s=N("strong"),a=j(c),l=j(" where the account creation will take place. If nothing happens check that if your browser is blocking popups, pleaase."),f=N("br"),u=j(` - After that you will be returned to this page.`),g=$(),h=N("button"),b=j("Start account creation »"),v(n,"class","text-center text-lg"),v(o,"class","mt-4 text-center text-sm leading-4"),v(h,"class",d="mt-4 block w-full cursor-pointer rounded border-0 px-2 py-1 text-lg text-white disabled:cursor-default disabled:bg-neutral-400 disabled:text-neutral-200 bg-"+t[0]+"-900 hover:bg-"+t[0]+"-950"),v(e,"class","m-auto w-full")},m(w,E){q(w,e,E),k(e,n),k(e,r),k(e,o),k(o,i),k(o,s),k(s,a),k(o,l),k(o,f),k(o,u),k(e,g),k(e,h),k(h,b),p||(y=J(h,"click",t[46]),p=!0)},p(w,E){E[0]&8192&&c!==(c=new URL(w[13]).host+"")&&Pe(a,c),E[0]&1&&d!==(d="mt-4 block w-full cursor-pointer rounded border-0 px-2 py-1 text-lg text-white disabled:cursor-default disabled:bg-neutral-400 disabled:text-neutral-200 bg-"+w[0]+"-900 hover:bg-"+w[0]+"-950")&&v(h,"class",d)},i:L,o:L,d(w){w&&R(e),p=!1,y()}}}function ho(t){let e,n,r=t[21].picture&&go(t),o=t[21].name&&po(t);return{c(){e=N("div"),r&&r.c(),n=$(),o&&o.c(),v(e,"class","mb-2 flex items-center justify-center gap-2")},m(i,s){q(i,e,s),r&&r.m(e,null),k(e,n),o&&o.m(e,null)},p(i,s){i[21].picture?r?r.p(i,s):(r=go(i),r.c(),r.m(e,n)):r&&(r.d(1),r=null),i[21].name?o?o.p(i,s):(o=po(i),o.c(),o.m(e,null)):o&&(o.d(1),o=null)},d(i){i&&R(e),r&&r.d(),o&&o.d()}}}function go(t){let e,n,r;return{c(){e=N("img"),Xe(e.src,n=t[21].picture)||v(e,"src",n),v(e,"alt",""),v(e,"class",r="h-10 w-10 rounded-full border-2 border-solid border-transparent group-hover:border-"+t[0]+"-100")},m(o,i){q(o,e,i)},p(o,i){i[0]&2097152&&!Xe(e.src,n=o[21].picture)&&v(e,"src",n),i[0]&1&&r!==(r="h-10 w-10 rounded-full border-2 border-solid border-transparent group-hover:border-"+o[0]+"-100")&&v(e,"class",r)},d(o){o&&R(e)}}}function po(t){let e,n=t[21].name+"",r;return{c(){e=N("div"),r=j(n),v(e,"class","text-3xl decoration-2 underline-offset-4 group-hover:underline")},m(o,i){q(o,e,i),k(e,r)},p(o,i){i[0]&2097152&&n!==(n=o[21].name+"")&&Pe(r,n)},d(o){o&&R(e)}}}function bo(t){let e,n;return{c(){e=N("div"),n=j(t[19]),v(e,"class","my-2 rounded bg-yellow-100 p-2 text-center text-sm leading-4 text-red-400")},m(r,o){q(r,e,o),k(e,n)},p(r,o){o[0]&524288&&Pe(n,r[19])},d(r){r&&R(e)}}}function Vc(t){let e;return{c(){e=j("Connect »")},m(n,r){q(n,e,r)},i:L,o:L,d(n){n&&R(e)}}}function Gc(t){let e,n,r;return n=new lo({}),{c(){e=j(`Connecting to bunker - `),Yn(n.$$.fragment)},m(o,i){q(o,e,i),Yt(n,o,i),r=!0},i(o){r||(de(n.$$.fragment,o),r=!0)},o(o){be(n.$$.fragment,o),r=!1},d(o){o&&R(e),Ft(n,o)}}}function wo(t){let e,n,r,o,i;return{c(){e=N("div"),n=j(`Waiting too much? - `),r=N("button"),r.textContent="Cancel the connection",v(r,"class","cursor-pointer border-0 bg-transparent text-sm text-white underline"),v(e,"class","mt-6 text-center text-sm leading-3")},m(s,c){q(s,e,c),k(e,n),k(e,r),o||(i=J(r,"click",t[39]),o=!0)},p:L,d(s){s&&R(e),o=!1,i()}}}function yo(t){let e,n,r,o,i,s,c;return{c(){e=N("div"),n=j("Do you need a Nostr account?"),r=N("br"),o=$(),i=N("button"),i.textContent="Sign up now",v(i,"class","cursor-pointer border-0 bg-transparent text-sm text-white underline"),v(e,"class","mt-6 text-center text-sm leading-3")},m(a,l){q(a,e,l),k(e,n),k(e,r),k(e,o),k(e,i),s||(c=J(i,"click",t[35]),s=!0)},p:L,d(a){a&&R(e),s=!1,c()}}}function mo(t){let e,n,r;return{c(){e=N("option"),v(e,"label",n=t[78].domain),e.__value=r=t[78],et(e,e.__value),v(e,"class","px-2 py-1 text-lg")},m(o,i){q(o,e,i)},p(o,i){i[0]&4194304&&n!==(n=o[78].domain)&&v(e,"label",n),i[0]&4194304&&r!==(r=o[78])&&(e.__value=r,et(e,e.__value))},d(o){o&&R(e)}}}function Zc(t){let e,n;return{c(){e=N("img"),Xe(e.src,n=t[21].picture)||v(e,"src",n),v(e,"alt",""),v(e,"class","h-6 w-6 rounded-full")},m(r,o){q(r,e,o)},p(r,o){o[0]&2097152&&!Xe(e.src,n=r[21].picture)&&v(e,"src",n)},i:L,o:L,d(r){r&&R(e)}}}function Yc(t){let e,n,r,o=(t[21].name||t[21].npub.slice(0,7)+"…"+t[21].npub.slice(-4))+"",i;function s(l,f){return l[21].picture?ea:Xc}let c=s(t),a=c(t);return{c(){e=N("div"),a.c(),n=$(),r=N("div"),i=j(o),v(r,"class","max-w-56 overflow-hidden whitespace-nowrap overflow-ellipsis inline-block"),v(e,"class","flex px-2 items-center")},m(l,f){q(l,e,f),a.m(e,null),k(e,n),k(e,r),k(r,i)},p(l,f){c===(c=s(l))&&a?a.p(l,f):(a.d(1),a=c(l),a&&(a.c(),a.m(e,n))),f[0]&2097152&&o!==(o=(l[21].name||l[21].npub.slice(0,7)+"…"+l[21].npub.slice(-4))+"")&&Pe(i,o)},i:L,o:L,d(l){l&&R(e),a.d()}}}function Fc(t){let e;return{c(){e=N("div"),e.textContent="N",v(e,"class","w-6 text-center")},m(n,r){q(n,e,r)},p:L,i:L,o:L,d(n){n&&R(e)}}}function Jc(t){let e;return{c(){e=N("div"),e.textContent="Connect with Nostr",v(e,"class","flex px-2 items-center")},m(n,r){q(n,e,r)},p:L,i:L,o:L,d(n){n&&R(e)}}}function Qc(t){let e,n,r,o;return r=new lo({}),{c(){e=N("div"),n=j(`Connecting to bunker - `),Yn(r.$$.fragment),v(e,"class","flex px-2 items-center")},m(i,s){q(i,e,s),k(e,n),Yt(r,e,null),o=!0},p:L,i(i){o||(de(r.$$.fragment,i),o=!0)},o(i){be(r.$$.fragment,i),o=!1},d(i){i&&R(e),Ft(r)}}}function Xc(t){let e;return{c(){e=j("☉")},m(n,r){q(n,e,r)},p:L,d(n){n&&R(e)}}}function ea(t){let e,n;return{c(){e=N("img"),Xe(e.src,n=t[21].picture)||v(e,"src",n),v(e,"alt",""),v(e,"class","mr-2 h-5 w-5 rounded-full")},m(r,o){q(r,e,o)},p(r,o){o[0]&2097152&&!Xe(e.src,n=r[21].picture)&&v(e,"src",n)},d(r){r&&R(e)}}}function ta(t){let e,n,r,o,i,s,c;const a=[qc,Hc,Rc],l=[];function f(u,g){return!u[25]&&!u[21]&&u[1]?0:u[25]?2:1}return n=f(t),r=l[n]=a[n](t),{c(){e=N("div"),r.c(),v(e,"class","draggable animate-fadein font-sans text-white"),v(e,"style",o="position: fixed; "+(t[25]&&t[5]?"width: 100vw;":"")+"; right: "+(t[25]&&t[5]?"0":t[3])+"px; user-select: none; "+(t[25]&&t[5]?"bottom: 0px":t[24]+":"+t[23]+"px")),Wn(e,"cursor-pointer",!t[21]&&!t[25])},m(u,g){q(u,e,g),l[n].m(e,null),t[54](e),i=!0,s||(c=[J(Rn,"click",t[29]),J(Rn,"mouseup",t[42]),J(Rn,"mousemove",t[41]),J(e,"mousedown",t[40])],s=!0)},p(u,g){let h=n;n=f(u),n===h?l[n].p(u,g):(At(),be(l[h],1,1,()=>{l[h]=null}),Bt(),r=l[n],r?r.p(u,g):(r=l[n]=a[n](u),r.c()),de(r,1),r.m(e,null)),(!i||g[0]&58720296&&o!==(o="position: fixed; "+(u[25]&&u[5]?"width: 100vw;":"")+"; right: "+(u[25]&&u[5]?"0":u[3])+"px; user-select: none; "+(u[25]&&u[5]?"bottom: 0px":u[24]+":"+u[23]+"px")))&&v(e,"style",o),(!i||g[0]&35651584)&&Wn(e,"cursor-pointer",!u[21]&&!u[25])},i(u){i||(de(r),i=!0)},o(u){be(r),i=!1},d(u){u&&R(e),l[n].d(),t[54](null),s=!1,Ne(c)}}}const vo="We could not connect to a NIP-46 bunker with that url, are you sure it is set up correctly?",xo="We were not able to connect using this address. For it to work it has to come from a NIP-46 provider.",ze=20;function Hn(t){return window.open(t,"window.nostr","width=600,height=800,popup=yes")}function na(t,e,n){let r,o,i,s,c,a;const l=Lc("only screen and (max-width: 640px)");Uo(t,l,I=>n(5,a=I));const f={ORIGIN:"wnj:origin",CLIENT_SECRET:"wnj:clientSecret",Y_POS:"wnj:ypos",CALLBACK_TOKEN:"wnj:callbackToken",BUNKER_POINTER:"wnj:bunkerPointer"};let u,{accent:g}=e,{position:h="top"}=e,{startHidden:b}=e,{compactMode:d}=e;const p=window,y=new As;let w,E,O,P,S,_;const m=localStorage.getItem(f.CLIENT_SECRET);m?_=en(m):(_=cs(),localStorage.setItem(f.CLIENT_SECRET,ne(_)));let A="closed",C,U,G,Z,Y,B,T=null,H=null,z=null,M=!1,K,ee,V,fe=!1,F,he,ge=[],{right:pe=20}=e,Je=!1,ce=!1,Be,Et,Ie;const ie={pool:y,onauth(I){K?n(13,T=I):F?(n(15,z=I),n(25,i=!0)):n(14,H=I)}},Oe=Xn(()=>{switch(A){case"justopened":n(44,A="opened");break;case"justclosed":n(44,A="closed");break}},500);function Qe(){n(44,A="justopened"),Oe()}function $e(){n(44,A="justclosed"),Oe()}function Kt(){if(C&&!B){zn();return}Qe()}Mn();let To={isWnj:!0,async getPublicKey(){return C?C.pubkey:(!Y&&!B&&Qe(),(await Z).bp.pubkey)},async signEvent(I){try{return!Y&&!B&&Kt(),await(await Z).signEvent(I)}finally{n(15,z=null),$e()}},async getRelays(){return!Y&&!B&&Kt(),(await Z).getRelays()},nip04:{async encrypt(I,D){return!Y&&!B&&Kt(),(await Z).nip04Encrypt(I,D)},async decrypt(I,D){return!Y&&!B&&Kt(),(await Z).nip04Decrypt(I,D)}}};function Mn(){$e(),C=null,Z=new Promise((I,D)=>{U=I,G=D}),n(21,F=null),n(12,Y=!1),n(16,M=!1),n(17,K=!1),B=!1,he=null,n(19,V="")}$o(()=>{if(!C){let I=localStorage.getItem(f.BUNKER_POINTER);I&&(C=JSON.parse(I),$n())}if(p.nostr&&!p.nostr.isWnj){p.destroyWnj();return}else Object.defineProperty(window,"nostr",{get(){return To},set(I){To=I,I.isWnj||p.destroyWnj()},configurable:!0});return()=>{he&&he.close()}});function sa(I){Math.abs(o-Et)>6||Date.now()-Ie>600||A==="justopened"||A==="justclosed"||(I.composedPath().find(D=>D.id==="wnj")?Qe():$e())}function ca(I){$e(),n(17,K=!1),n(13,T=null),n(14,H=null),n(15,z=null),I.stopPropagation()}function aa(I){n(20,fe=!0),I.stopPropagation()}function la(I){n(20,fe=!1),I.stopPropagation()}async function ua(I){I.preventDefault();try{if(C=await Sc(w.value),!C){w.value.match($t)?n(19,V=vo):n(19,V=xo);return}w.setCustomValidity(""),n(19,V=""),await zn(),$n()}catch{w.value.match($t)?n(19,V=vo):n(19,V=xo),n(12,Y=!1)}}async function fa(I){I.preventDefault(),localStorage.removeItem(f.BUNKER_POINTER),Mn()}async function da(I){I.preventDefault(),n(17,K=!0),ge.length===0&&(n(22,ge=await Bc(y,["wss://relay.nostr.band","wss://nos.lol","wss://nostr-pub.wellorder.net"])),n(10,S=ge[0]))}function ha(I){n(17,K=!1)}async function ga(I){if(I.preventDefault(),!S)return;n(18,ee=!0);let D=await Ac(S,ie,O.value,S.domain,void 0);n(18,ee=!1),Qe(),n(17,K=!1),C=D.bp,$n(),zn(D)}const pa=Xn(async()=>{S&&O.value.length>0&&(await Ic(O.value+"@"+S.domain)?O.setCustomValidity(`'${O.value}' is already taken.`):O.setCustomValidity(""))},500);function ba(){n(16,M=!1),n(12,Y=!1),G("connection aborted"),Mn()}async function zn(I=void 0){I=I||new so(_,C,ie),n(12,Y=!0);let D=setTimeout(()=>{n(16,M=!0),n(25,i=!0)},5e3);try{await I.connect(),B=!0,localStorage.setItem(f.BUNKER_POINTER,JSON.stringify(C)),$e(),U(I)}catch(xe){G((xe==null?void 0:xe.message)||String(xe))}finally{clearTimeout(D),n(12,Y=!1),n(16,M=!1),n(13,T=null),n(14,H=null),n(15,z=null)}}function $n(I=null){let D=C.pubkey;n(21,F={pubkey:D,npub:Tc(D),event:null}),he=y.subscribeMany(["wss://purplepag.es","wss://relay.snort.social","wss://relay.nos.social"],[{kinds:[0],authors:[D]}],{onevent(xe){var No;if(!((((No=F.event)==null?void 0:No.created_at)||0)>=xe.created_at))try{let{name:Po,picture:Oa}=JSON.parse(xe.content);n(21,F.event=xe,F),n(21,F.name=Po,F),n(21,F.picture=Oa,F),I==null||I(),I=null}catch{}}})}function wa(I){if(i)return;Je=!0;const D=u.getBoundingClientRect();Be=I.clientY-D.top,Et=o,Ie=Date.now()}function ya(I){Je&&(r==="top"?n(23,o=I.clientY):n(23,o=window.innerHeight-I.clientY),n(23,o-=Be),n(45,ce=!0),o| sha256 | -Type | -Size | -- |
|---|---|---|---|
| - ${blob.sha256} - | -${blob.type} | -${formatBytes(blob.size)} | -- - Delete - - | -
${this.status}
`; - } else if (this.blobs) { - if (this.blobs.length === 0) return html`Set pubkey
`; - - return this.renderResults(); - } - - return html`Set pubkey
`; - } - - render() { - if (this.status) { - return html`${this.status}
`; - } - - return html`
-
`;
- }
-}
-customElements.define("list-blobs", ListForm);
diff --git a/public/main.js b/public/main.js
deleted file mode 100644
index ed9f1b0..0000000
--- a/public/main.js
+++ /dev/null
@@ -1,49 +0,0 @@
-import { html, LitElement } from "./lib/lit.min.js";
-import "./upload-form.js";
-import "./list-blobs.js";
-import "./mirror-blobs.js";
-
-export class BlossomApp extends LitElement {
- static properties = {
- selected: { state: true },
- status: { state: true, type: String },
- };
-
- createRenderRoot() {
- return this;
- }
-
- connectedCallback() {
- super.connectedCallback();
- window.addEventListener("hashchange", () => {
- this.requestUpdate();
- });
- }
-
- render() {
- const hash = location.hash;
-
- let content = "";
- switch (hash) {
- case "#list":
- content = html`
-
-
- ${this.renderContent()}
-
- List blobs
- ${this.renderForm()} -
- back to upload
-
- 🌸 Blossom Spec
-
-
-
- ${content}
-
`;
- }
-}
-
-customElements.define("blossom-app", BlossomApp);
diff --git a/public/mirror-blobs.js b/public/mirror-blobs.js
deleted file mode 100644
index 29c5c75..0000000
--- a/public/mirror-blobs.js
+++ /dev/null
@@ -1,251 +0,0 @@
-import { html, LitElement } from "./lib/lit.min.js";
-import { formatBytes, newExpirationValue, unixNow } from "./utils.js";
-
-export class MirrorBlobs extends LitElement {
- static properties = {
- remoteBlobs: { state: true },
- localBlobs: { state: true },
-
- status: { state: true, type: String },
- progress: { state: true },
-
- server: { state: true, type: String },
- selected: { state: true },
- };
-
- createRenderRoot() {
- return this;
- }
-
- constructor() {
- super();
- this.selected = [];
- }
-
- async fetchRemoteBlobs() {
- if (!this.server) return;
-
- const pubkey = await window.nostr.getPublicKey();
-
- this.status = "Signing...";
- const auth = await window.nostr.signEvent({
- kind: 24242,
- content: "List Blobs",
- created_at: unixNow(),
- tags: [
- ["t", "list"],
- ["expiration", newExpirationValue()],
- ["server", new URL("/", this.server).toString()],
- ],
- });
-
- this.status = "Fetching...";
- this.remoteBlobs = await fetch(new URL("/list/" + pubkey, this.server), {
- headers: { authorization: "Nostr " + btoa(JSON.stringify(auth)) },
- }).then((res) => res.json());
-
- this.status = undefined;
- }
-
- localAuth = null;
- async fetchLocalBlobs() {
- this.pubkey = await window.nostr?.getPublicKey();
- if (!this.pubkey) return;
-
- this.status = "Signing...";
-
- this.localAuth = await window.nostr.signEvent({
- kind: 24242,
- content: "List Blobs",
- created_at: unixNow(),
- tags: [
- ["t", "list"],
- ["expiration", newExpirationValue()],
- ["server", new URL(location.protocol + "//" + location.hostname).toString()],
- ],
- });
-
- this.status = "Fetching...";
-
- this.localBlobs = await fetch("/list/" + this.pubkey, {
- headers: { authorization: "Nostr " + btoa(JSON.stringify(this.localAuth)) },
- }).then((res) => res.json());
-
- this.status = undefined;
- }
-
- async submit(e) {
- e.preventDefault();
-
- await this.fetchLocalBlobs();
- await this.fetchRemoteBlobs();
- }
-
- serverChange(e) {
- this.server = e.target.value;
- }
-
- renderForm() {
- return html``;
- }
-
- selectAll() {
- const missingBlobs = this.remoteBlobs.filter((blob) => !this.localBlobs.some((b) => b.sha256 === blob.sha256));
-
- if (this.selected.length === missingBlobs.length) {
- this.selected = [];
- } else this.selected = missingBlobs.map((b) => b.sha256);
- }
- toggleSelection(sha256) {
- if (this.selected.includes(sha256)) {
- this.selected = this.selected.filter((s) => s !== sha256);
- } else this.selected = [...this.selected, sha256];
- }
-
- async mirrorBlobs() {
- const blobs = this.remoteBlobs.filter((blob) => this.selected.includes(blob.sha256));
-
- for (const blob of blobs) {
- this.progress = blobs.indexOf(blob) + 1;
- this.status = `Signing ${blob.sha256}`;
-
- // create auth event
- const auth = await window.nostr.signEvent({
- kind: 24242,
- content: "Mirror Blob",
- created_at: unixNow(),
- tags: [
- ["t", "upload"],
- ["x", blob.sha256],
- ["expiration", newExpirationValue()],
- ],
- });
-
- this.status = `Mirroring ${blob.sha256}`;
- await fetch("/mirror", {
- method: "PUT",
- body: JSON.stringify({ url: blob.url }),
- headers: { authorization: "Nostr " + btoa(JSON.stringify(auth)), "Content-Type": "application/json" },
- });
- }
-
- this.progress = undefined;
- this.status = undefined;
-
- this.selected = [];
- await this.fetchLocalBlobs();
- }
-
- renderContent() {
- if (!window.nostr) return html`Missing window.nostr extension
`; - - if (this.progress !== undefined) { - return html` -${this.progress}/${this.selected.length} - ${this.status}
- - `; - } else if (this.status) { - return html`${this.status}
`; - } else if (this.remoteBlobs && this.localBlobs) { - const missingBlobs = this.remoteBlobs.filter((blob) => !this.localBlobs.some((b) => b.sha256 === blob.sha256)); - - if (missingBlobs.length === 0) { - return html`All blobs synced ✅
`; - } - - return html` -
-
-
-
- ${this.renderBlobs(missingBlobs)}
- `;
- }
-
- return html`Select Blossom Server
`; - } - - renderBlobs(blobs = []) { - return html`| - | sha256 | -Type | -Size | -
|---|---|---|---|
| - - | -- ${blob.sha256} - | -${blob.type} | -${formatBytes(blob.size)} | -
-
`;
- }
-}
-customElements.define("mirror-blobs", MirrorBlobs);
diff --git a/public/open-blob-form.js b/public/open-blob-form.js
deleted file mode 100644
index 1ed0c54..0000000
--- a/public/open-blob-form.js
+++ /dev/null
@@ -1,63 +0,0 @@
-import { html, LitElement } from "./lib/lit.min.js";
-
-export class GetBlobForm extends LitElement {
- static properties = {
- hasBlob: { state: true },
- };
-
- createRenderRoot() {
- return this;
- }
-
- async submit(e) {
- e.preventDefault();
-
- const formData = new FormData(e.target);
- const sha256 = formData.get("sha256");
-
- this.hasBlob = await fetch("/" + sha256, { method: "HEAD" }).then((res) => res.ok);
-
- if (this.hasBlob) {
- window.open("/" + sha256, "_blank");
- }
- }
-
- renderResults() {
- return html`
-
-
- ${this.renderContent()}
-
- Mirror blobs
- ${window.nostr && this.renderForm()} -
- back to upload
-
- 🌸 Blossom Spec
-
-
- ${this.blobs.map(
- (blob) => html`
-
`;
- }
-
- renderForm() {
- return html``;
- }
-
- render() {
- if (this.blob) {
- return this.renderResults();
- }
-
- return this.renderForm();
- }
-}
-customElements.define("get-blob-form", GetBlobForm);
diff --git a/public/upload-form.js b/public/upload-form.js
deleted file mode 100644
index dcdd7f4..0000000
--- a/public/upload-form.js
+++ /dev/null
@@ -1,159 +0,0 @@
-import { html, LitElement } from "./lib/lit.min.js";
-import { unixNow, newExpirationValue, getFileSha256, formatBytes } from "./utils.js";
-
-import "./open-blob-form.js";
-
-export class UploadForm extends LitElement {
- static properties = {
- selected: { state: true },
- status: { state: true, type: String },
- };
-
- createRenderRoot() {
- return this;
- }
-
- async upload(e) {
- e.preventDefault();
-
- try {
- if (!this.selected) throw new Error("Select file first");
-
- let file = this.selected;
-
- // handle an edge case where some browsers set the mime type of .m3u8 files to audio/x-mpegurl
- if (file.type === "audio/x-mpegurl" && file.name.endsWith(".m3u8")) {
- file = new File([file], file.name, {
- type: "application/vnd.apple.mpegurl",
- });
- }
-
- this.status = "Compute SHA256 hash...";
- const hash = await getFileSha256(file);
-
- this.status = "Signing...";
-
- // create auth event
- const auth = await window.nostr.signEvent({
- kind: 24242,
- content: "Authorize Upload",
- created_at: unixNow(),
- tags: [
- ["t", "upload"],
- ["x", hash],
- ["expiration", newExpirationValue()],
- ],
- });
- const authorization = "Nostr " + btoa(JSON.stringify(auth));
-
- // BUD-06 check upload
- this.status = "Checking Upload...";
- const check = await fetch("/upload", {
- method: "HEAD",
- headers: {
- authorization,
- "X-Content-Type": file.type,
- "X-Content-Length": file.size,
- "X-Sha-256": hash,
- },
- });
-
- if (!check.ok) {
- throw new Error(check.headers.get("x-upload-message") || "Upload Rejected");
- }
-
- // Upload blob
- this.status = "Uploading...";
- const res = await fetch("/upload", {
- method: "PUT",
- body: file,
- // attach Authorization: Nostr
- ${blob.sha256}
-
- `,
- )}
-
-
-
`
- : html`
- Drag and drop files here
- or select a file from your computer
-
${this.selected.name}
-${formatBytes(this.selected.size)}
`; - - return html``; - } -} -customElements.define("upload-form", UploadForm); diff --git a/public/utils.js b/public/utils.js deleted file mode 100644 index 007668c..0000000 --- a/public/utils.js +++ /dev/null @@ -1,55 +0,0 @@ -export const unixNow = () => Math.floor(Date.now() / 1000); -export const newExpirationValue = () => (unixNow() + 60 * 5).toString(); - -export function readBlobAsArrayBuffer(file) { - return new Promise((resolve, reject) => { - const reader = new FileReader(); - reader.onload = (e) => { - const result = e.target?.result; - if (result == undefined || typeof result !== "object") { - reject(); - return; - } - resolve(result); - }; - reader.onerror = (error) => reject(error); - reader.readAsArrayBuffer(file); - }); -} - -export async function getFileSha256(file) { - const { bytesToHex } = await import("./lib/@noble/hashes/utils.js"); - const buffer = file instanceof File ? await file.arrayBuffer() : await readBlobAsArrayBuffer(file); - let hash; - if (crypto.subtle) { - const hashBuffer = await crypto.subtle.digest("SHA-256", buffer); - hash = new Uint8Array(hashBuffer); - } else { - const { sha256 } = await import("./lib/@noble/hashes/sha256.js"); - hash = sha256.create().update(new Uint8Array(buffer)).digest(); - } - return bytesToHex(hash); -} - -// Copied from https://git.v0l.io/Kieran/dtan/src/branch/main/src/const.ts#L220 -export const kiB = Math.pow(1024, 1); -export const MiB = Math.pow(1024, 2); -export const GiB = Math.pow(1024, 3); -export const TiB = Math.pow(1024, 4); -export const PiB = Math.pow(1024, 5); -export const EiB = Math.pow(1024, 6); -export const ZiB = Math.pow(1024, 7); -export const YiB = Math.pow(1024, 8); - -export function formatBytes(b, f) { - f ??= 2; - if (b >= YiB) return (b / YiB).toFixed(f) + " YiB"; - if (b >= ZiB) return (b / ZiB).toFixed(f) + " ZiB"; - if (b >= EiB) return (b / EiB).toFixed(f) + " EiB"; - if (b >= PiB) return (b / PiB).toFixed(f) + " PiB"; - if (b >= TiB) return (b / TiB).toFixed(f) + " TiB"; - if (b >= GiB) return (b / GiB).toFixed(f) + " GiB"; - if (b >= MiB) return (b / MiB).toFixed(f) + " MiB"; - if (b >= kiB) return (b / kiB).toFixed(f) + " KiB"; - return b.toFixed(f) + " B"; -} diff --git a/src/admin-api/auth.ts b/src/admin-api/auth.ts deleted file mode 100644 index 54854eb..0000000 --- a/src/admin-api/auth.ts +++ /dev/null @@ -1,5 +0,0 @@ -import router from "./router.js"; - -router.all("/auth", (ctx) => { - ctx.body = { success: true }; -}); diff --git a/src/admin-api/blobs.ts b/src/admin-api/blobs.ts deleted file mode 100644 index 2699fa5..0000000 --- a/src/admin-api/blobs.ts +++ /dev/null @@ -1,69 +0,0 @@ -import router from "./router.js"; -import db, { blobDB } from "../db/db.js"; -import { getBlobURL } from "../helpers/blob.js"; -import storage from "../storage/index.js"; -import { parseGetListQuery, setContentRange } from "./helpers.js"; -import { buildConditionsFromFilter, buildOrderByFromSort } from "../helpers/sql.js"; -import { Request } from "koa"; - -function blobRowToBlob(row: any, req?: Request) { - return { - ...row, - owners: row.owners?.split(",") ?? [], - id: row.sha256, - url: getBlobURL(row, req ? req.protocol + "://" + req.host : undefined), - }; -} -function safeColumn(name: string) { - if (["sha256", "type", "size", "uploaded"].includes(name)) return name; - throw new Error("Invalid table name"); -} - -// getOne -router.get("/blobs/:id", (ctx) => { - const row = db.prepare(baseBlobSql + " WHERE sha256 = ?" + groupByBlobHash).get(ctx.params.id); - if (row) ctx.body = blobRowToBlob(row, ctx.request); -}); - -// delete blob -router.delete("/blobs/:id", async (ctx) => { - await blobDB.removeBlob(ctx.params.id); - if (await storage.hasBlob(ctx.params.id)) await storage.removeBlob(ctx.params.id); - ctx.body = { success: true }; -}); - -// getList / getMany -const baseBlobSql = ` -SELECT blobs.*,GROUP_CONCAT(owners.pubkey, ',') as owners FROM blobs - LEFT JOIN owners ON owners.blob = blobs.sha256 -`.trim(); -const groupByBlobHash = " GROUP BY blobs.sha256"; - -router.get("/blobs", (ctx) => { - let sql = baseBlobSql; - let params: (string | number)[] = []; - - const { filter, sort, range } = parseGetListQuery(ctx.query); - - const conditions = buildConditionsFromFilter(filter, ["sha256", "type"], safeColumn); - - sql += conditions.sql; - params.push(...conditions.params); - - sql += groupByBlobHash; - - sql += buildOrderByFromSort(sort, safeColumn); - - if (range) { - sql += " LIMIT ? OFFSET ?"; - params.push(range[1] - range[0], range[0]); - } - - const total = ( - db.prepare("SELECT COUNT(*) as count FROM blobs" + conditions.sql).get(conditions.params) as { count: number } - ).count; - const blobs = db.prepare(sql).all(...params) as any[]; - - setContentRange(ctx, range, blobs, total); - ctx.body = blobs.map((r) => blobRowToBlob(r, ctx.request)); -}); diff --git a/src/admin-api/helpers.ts b/src/admin-api/helpers.ts deleted file mode 100644 index 93967bb..0000000 --- a/src/admin-api/helpers.ts +++ /dev/null @@ -1,28 +0,0 @@ -import { ParameterizedContext } from "koa"; -import { ParsedUrlQuery } from "querystring"; - -export type GetListQuery = Partial<{ - sort: [string, string]; - range: [number, number]; - filter: Record