commit 079db693f14313819434b6f8c2b4c8db552cc68e · mewsse.pet/pet.mewsse.link

+3 -1

.env.example

···

       1
       1
        
       DB_PATH=":memory:"

     

       2
       2
        
       DID="did:plc:you_did_here"

     

       3
       3
       -
       LOG_LEVEL="INFO"
     

       3
       3
       +
       LOG_LEVEL="INFO"

     

       4
       4
       +
       ITEM_PER_PAGES="10"

     

       5
       5
       +
       PORT="8080"

+18

compose.yml

···

       1
       1
       +
       services:

     

       2
       2
       +
         links:

     

       3
       3
       +
           container_name: links

     

       4
       4
       +
           build: .

     

       5
       5
       +
           restart: unless-stopped

     

       6
       6
       +
           environment:

     

       7
       7
       +
             DB_PATH: "/links/db.db"

     

       8
       8
       +
             DID: "did:plc:w7x22x56pgtta23uulbcahbo"

     

       9
       9
       +
             LOG_LEVEL: "INFO"

     

       10
       10
       +
             ITEM_PER_PAGES: 10

     

       11
       11
       +
             PORT: "8080"

     

       12
       12
       +
           volumes:

     

       13
       13
       +
             - type: bind

     

       14
       14
       +
               source: ./links

     

       15
       15
       +
               target: /links

     

       16
       16
       +
           ports:

     

       17
       17
       +
             - 8080:8080

     

       18
       18
       +

+4 -4

src/ingester.ts

···

       61
       61
        
             for await (const entry of repo) {

     

       62
       62
        
               if (!repoRev) repoRev = entry.rkey

     

       63
       63
        
               if (entry.collection != "pet.mewsse.link") continue

     

       64
       64
       +
       

     

       64
       65
        
               const link = decode(entry.bytes)

     

       65
       65
       -
               console.log(link)

     

       66
       66
       +
               const embed = await findEmbed(did, pds, link.embed)

     

       66
       67
        
       

     

       67
       68
        
               links.push({

     

       68
       69
        
                 rkey: entry.rkey,

     

       69
       70
        
                 url: link.url,

     

       70
       71
        
                 title: link.title,

     

       71
       72
        
                 description: link.description,

     

       72
       72
       -
                 embed: await findEmbed(did, pds, link.embed),

     

       73
       73
       +
                 embed: embed,

     

       73
       74
        
                 nsfw: +(link.nsfw || 0),

     

       74
       75
        
                 createdAt: link.createdAt

     

       75
       76
        
               })

     
···

       78
       79
        
             links = links.sort((a, b) => a.createdAt > b.createdAt ? 1 : -1)

     

       79
       80
        
       

     

       80
       81
        
             for await (const link of links) {

     

       81
       81
       -
               const embed = await findEmbed(did, pds, link.embed)

     

       82
       82
        
               await db

     

       83
       83
        
                 .insertInto('links')

     

       84
       84
        
                 .values(link)

     
···

       87
       87
        
                     url: link.url,

     

       88
       88
        
                     title: link.title,

     

       89
       89
        
                     description: link.description,

     

       90
       90
       -
                     embed: embed,

     

       90
       90
       +
                     embed: link.embed,

     

       91
       91
        
                     nsfw: +(link.nsfw || 0),

     

       92
       92
        
                   })

     

       93
       93
        
                 )