comparing 33cff573744a53e41c47e08be091c340f38f0287 and main on gracekind.net/tangled-pages

+5 -4

src/server.js

···

       22
       22
        
           });

     

       23
       23
        
         }

     

       24
       24
        
       

     

       25
       25
       -
         async start() {

     

       26
       26
       -
           this.app.listen(3000, () => {

     

       27
       27
       -
             console.log("Server is running on port 3000");

     

       25
       25
       +
         async start({ port }) {

     

       26
       26
       +
           this.app.listen(port, () => {

     

       27
       27
       +
             console.log(`Server is running on port ${port}`);

     

       28
       28
        
           });

     

       29
       29
        
           this.app.on("error", (error) => {

     

       30
       30
        
             console.error("Server error:", error);

     
···

       34
       34
        
       

     

       35
       35
        
       async function main() {

     

       36
       36
        
         const args = yargs(process.argv.slice(2)).parse();

     

       37
       37
       +
         const port = args.port ?? args.p ?? 3000;

     

       37
       38
        
         const configFilepath = args.config || "config.json";

     

       38
       39
        
         const config = await Config.fromFile(configFilepath);

     

       39
       40
        
         const handler = await Handler.fromConfig(config);

     

       40
       41
        
         const server = new Server({

     

       41
       42
        
           handler,

     

       42
       43
        
         });

     

       43
       43
       -
         await server.start();

     

       44
       44
       +
         await server.start({ port });

     

       44
       45
        
       }

     

       45
       46
        
       

     

       46
       47
        
       main();

+8

config.multiple.example.json

···

       7
       7
        
             "branch": "main",

     

       8
       8
        
             "baseDir": "/public",

     

       9
       9
        
             "notFoundFilepath": "/404.html"

     

       10
       10
       +
           },

     

       11
       11
       +
           {

     

       12
       12
       +
             "subdomain": "url-example",

     

       13
       13
       +
             "tangledUrl": "https://tangled.sh/@gracekind.net/tangled-pages-example",

     

       14
       14
       +
             "tangledUrl:comment": "This will render the same site as above, but it's an example of how to use the tangledUrl field",

     

       15
       15
       +
             "branch": "main",

     

       16
       16
       +
             "baseDir": "/public",

     

       17
       17
       +
             "notFoundFilepath": "/404.html"

     

       10
       18
        
           }

     

       11
       19
        
         ],

     

       12
       20
        
         "subdomainOffset": 1,

+12

src/atproto.js

···

       10
       10
        
         return service.serviceEndpoint;

     

       11
       11
        
       }

     

       12
       12
        
       

     

       13
       13
       +
       export async function resolveHandle(handle) {

     

       14
       14
       +
         const params = new URLSearchParams({

     

       15
       15
       +
           handle,

     

       16
       16
       +
         });

     

       17
       17
       +
         const res = await fetch(

     

       18
       18
       +
           "https://public.api.bsky.app/xrpc/com.atproto.identity.resolveHandle?" +

     

       19
       19
       +
             params.toString()

     

       20
       20
       +
         );

     

       21
       21
       +
         const data = await res.json();

     

       22
       22
       +
         return data.did;

     

       23
       23
       +
       }

     

       24
       24
       +
       

     

       13
       25
        
       async function resolveDid(did) {

     

       14
       26
        
         if (did.startsWith("did:plc:")) {

     

       15
       27
        
           const res = await fetch(`https://plc.directory/${encodeURIComponent(did)}`);

+30 -2

src/config.js

···

       1
       1
       +
       class SiteConfig {

     

       2
       2
       +
         constructor({

     

       3
       3
       +
           tangledUrl,

     

       4
       4
       +
           knotDomain,

     

       5
       5
       +
           ownerDid,

     

       6
       6
       +
           repoName,

     

       7
       7
       +
           branch,

     

       8
       8
       +
           baseDir,

     

       9
       9
       +
           notFoundFilepath,

     

       10
       10
       +
         }) {

     

       11
       11
       +
           if (tangledUrl) {

     

       12
       12
       +
             if ([ownerDid, repoName].some((v) => !!v)) {

     

       13
       13
       +
               throw new Error("Cannot use ownerDid and repoName with url");

     

       14
       14
       +
             }

     

       15
       15
       +
           }

     

       16
       16
       +
           this.tangledUrl = tangledUrl;

     

       17
       17
       +
           this.ownerDid = ownerDid;

     

       18
       18
       +
           this.repoName = repoName;

     

       19
       19
       +
           this.knotDomain = knotDomain;

     

       20
       20
       +
           this.branch = branch;

     

       21
       21
       +
           this.baseDir = baseDir;

     

       22
       22
       +
           this.notFoundFilepath = notFoundFilepath;

     

       23
       23
       +
         }

     

       24
       24
       +
       }

     

       25
       25
       +
       

     

       1
       26
        
       export class Config {

     

       2
       27
        
         constructor({ site, sites, subdomainOffset, cache = false }) {

     

       3
       3
       -
           this.site = site;

     

       4
       4
       -
           this.sites = sites;

     

       28
       28
       +
           if (site && sites) {

     

       29
       29
       +
             throw new Error("Cannot use both site and sites in config");

     

       30
       30
       +
           }

     

       31
       31
       +
           this.site = site ? new SiteConfig(site) : null;

     

       32
       32
       +
           this.sites = sites ? sites.map((site) => new SiteConfig(site)) : null;

     

       5
       33
        
           this.subdomainOffset = subdomainOffset;

     

       6
       34
        
           this.cache = cache;

     

       7
       35
        
         }

+32 -14

src/handler.js

···

       1
       1
        
       import { PagesService } from "./pages-service.js";

     

       2
       2
        
       import { KnotEventListener } from "./knot-event-listener.js";

     

       3
       3
       -
       import { listRecords } from "./atproto.js";

     

       3
       3
       +
       import { listRecords, resolveHandle } from "./atproto.js";

     

       4
       4
        
       

     

       5
       5
        
       async function getKnotDomain(did, repoName) {

     

       6
       6
        
         const repos = await listRecords({

     
···

       14
       14
        
         return repo.value.knot;

     

       15
       15
        
       }

     

       16
       16
        
       

     

       17
       17
       +
       function parseTangledUrl(tangledUrl) {

     

       18
       18
       +
         // e.g. https://tangled.sh/@gracekind.net/tangled-pages-example

     

       19
       19
       +
         const regex = /^https:\/\/tangled\.sh\/@(.+)\/(.+)$/;

     

       20
       20
       +
         const match = tangledUrl.match(regex);

     

       21
       21
       +
         if (!match) {

     

       22
       22
       +
           throw new Error(`Invalid tangled URL: ${tangledUrl}`);

     

       23
       23
       +
         }

     

       24
       24
       +
         return {

     

       25
       25
       +
           handle: match[1],

     

       26
       26
       +
           repoName: match[2],

     

       27
       27
       +
         };

     

       28
       28
       +
       }

     

       29
       29
       +
       

     

       17
       30
        
       async function getPagesServiceForSite(siteOptions, config) {

     

       31
       31
       +
         // Fetch repoName and ownerDid if needed

     

       32
       32
       +
         let ownerDid = siteOptions.ownerDid;

     

       33
       33
       +
         let repoName = siteOptions.repoName;

     

       34
       34
       +
       

     

       35
       35
       +
         if (siteOptions.tangledUrl) {

     

       36
       36
       +
           const { handle, repoName: parsedRepoName } = parseTangledUrl(

     

       37
       37
       +
             siteOptions.tangledUrl

     

       38
       38
       +
           );

     

       39
       39
       +
           console.log("Getting ownerDid for", handle);

     

       40
       40
       +
           const did = await resolveHandle(handle);

     

       41
       41
       +
           ownerDid = did;

     

       42
       42
       +
           repoName = parsedRepoName;

     

       43
       43
       +
         }

     

       44
       44
       +
         // Fetch knot domain if needed

     

       18
       45
        
         let knotDomain = siteOptions.knotDomain;

     

       19
       46
        
         if (!knotDomain) {

     

       20
       20
       -
           console.log(

     

       21
       21
       -
             "Getting knot domain for",

     

       22
       22
       -
             siteOptions.ownerDid + "/" + siteOptions.repoName

     

       23
       23
       -
           );

     

       24
       24
       -
           knotDomain = await getKnotDomain(

     

       25
       25
       -
             siteOptions.ownerDid,

     

       26
       26
       -
             siteOptions.repoName

     

       27
       27
       -
           );

     

       47
       47
       +
           console.log("Getting knot domain for", ownerDid + "/" + repoName);

     

       48
       48
       +
           knotDomain = await getKnotDomain(ownerDid, repoName);

     

       28
       49
        
         }

     

       29
       50
        
         return new PagesService({

     

       30
       51
        
           knotDomain,

     

       31
       31
       -
           ownerDid: siteOptions.ownerDid,

     

       32
       32
       -
           repoName: siteOptions.repoName,

     

       52
       52
       +
           ownerDid,

     

       53
       53
       +
           repoName,

     

       33
       54
        
           branch: siteOptions.branch,

     

       34
       55
        
           baseDir: siteOptions.baseDir,

     

       35
       56
        
           notFoundFilepath: siteOptions.notFoundFilepath,

     
···

       38
       59
        
       }

     

       39
       60
        
       

     

       40
       61
        
       async function getPagesServiceMap(config) {

     

       41
       41
       -
         if (config.site && config.sites) {

     

       42
       42
       -
           throw new Error("Cannot use both site and sites in config");

     

       43
       43
       -
         }

     

       44
       62
        
         const pagesServiceMap = {};

     

       45
       63
        
         if (config.site) {

     

       46
       64
        
           pagesServiceMap[""] = await getPagesServiceForSite(config.site, config);

+2

README.md

···

       53
       53
        
       

     

       54
       54
        
       When `cache: false`, the server fetches files from the repo on every request, so it might be slow.

     

       55
       55
        
       

     

       56
       56
       +
       This library fetches html from the repo directly, so there's no build step. As a workaround, you can add a commit hook to build your site locally and include the built files in your repo (or as a git submodule).

     

       57
       57
       +
       

     

       56
       58
        
       ## To-do

     

       57
       59
        
       

     

       58
       60
        
       - support `cache: true` in workers

+13 -6

src/knot-client.js

···

       9
       9
        
         }

     

       10
       10
        
       

     

       11
       11
        
         async getBlob(filename) {

     

       12
       12
       -
           const url = `https://${this.domain}/${this.ownerDid}/${

     

       13
       13
       -
             this.repoName

     

       14
       14
       -
           }/blob/${this.branch}/${trimLeadingSlash(filename)}`;

     

       12
       12
       +
           const params = new URLSearchParams({

     

       13
       13
       +
             repo: `${this.ownerDid}/${this.repoName}`,

     

       14
       14
       +
             path: trimLeadingSlash(filename),

     

       15
       15
       +
             ref: this.branch,

     

       16
       16
       +
           });

     

       17
       17
       +
           const url = `https://${this.domain}/xrpc/sh.tangled.repo.blob?${params}`;

     

       15
       18
        
           console.log(`[KNOT CLIENT]: GET ${url}`);

     

       16
       19
        
           const res = await fetch(url);

     

       17
       20
        
           return await res.json();

     

       18
       21
        
         }

     

       19
       22
        
       

     

       20
       23
        
         async getRaw(filename) {

     

       21
       21
       -
           const url = `https://${this.domain}/${this.ownerDid}/${this.repoName}/raw/${

     

       22
       22
       -
             this.branch

     

       23
       23
       -
           }/${trimLeadingSlash(filename)}`;

     

       24
       24
       +
           const params = new URLSearchParams({

     

       25
       25
       +
             repo: `${this.ownerDid}/${this.repoName}`,

     

       26
       26
       +
             path: trimLeadingSlash(filename),

     

       27
       27
       +
             ref: this.branch,

     

       28
       28
       +
             raw: "true",

     

       29
       29
       +
           });

     

       30
       30
       +
           const url = `https://${this.domain}/xrpc/sh.tangled.repo.blob?${params}`;

     

       24
       31
        
           console.log(`[KNOT CLIENT]: GET ${url}`);

     

       25
       32
        
           const res = await fetch(url, {

     

       26
       33
        
             responseType: "arraybuffer",

+2 -2

src/pages-service.js

···

       67
       67
        
           }

     

       68
       68
        
           let content = null;

     

       69
       69
        
           const blob = await this.client.getBlob(filename);

     

       70
       70
       -
           if (blob.is_binary) {

     

       70
       70
       +
           if (blob.isBinary) {

     

       71
       71
        
             content = await this.client.getRaw(filename);

     

       72
       72
        
           } else {

     

       73
       73
       -
             content = blob.contents;

     

       73
       73
       +
             content = blob.content;

     

       74
       74
        
           }

     

       75
       75
        
           if (this.fileCache && content) {

     

       76
       76
        
             const contentSize = Buffer.isBuffer(content)

Compare changes