commit 9ae29a5cda031b478ff830a7f0d79f238621c368 · dunkirk.sh/cachet

+12 -4

src/cache.ts

···

       138
       138
        
          * Purges all items from the cache

     

       139
       139
        
          * @returns int indicating number of items purged

     

       140
       140
        
          */

     

       141
       141
       -
         async purgeAll(): Promise<number> {

     

       142
       142
       -
           const result = this.db.run("DELETE FROM users", [Date.now()]);

     

       143
       143
       -
           const result2 = this.db.run("DELETE FROM emojis", [Date.now()]);

     

       141
       141
       +
         async purgeAll(): Promise<{

     

       142
       142
       +
           message: string;

     

       143
       143
       +
           users: number;

     

       144
       144
       +
           emojis: number;

     

       145
       145
       +
         }> {

     

       146
       146
       +
           const result = this.db.run("DELETE FROM users");

     

       147
       147
       +
           const result2 = this.db.run("DELETE FROM emojis");

     

       144
       148
        
       

     

       145
       149
        
           if (this.onEmojiExpired) {

     

       146
       150
        
             if (result2.changes > 0) {

     
···

       148
       152
        
             }

     

       149
       153
        
           }

     

       150
       154
        
       

     

       151
       151
       -
           return result.changes + result2.changes;

     

       155
       155
       +
           return {

     

       156
       156
       +
             message: "Cache purged",

     

       157
       157
       +
             users: result.changes,

     

       158
       158
       +
             emojis: result2.changes,

     

       159
       159
       +
           };

     

       152
       160
        
         }

     

       153
       161
        
       

     

       154
       162
        
         /**

+27

src/index.ts

···

       422
       422
        
             }),

     

       423
       423
        
           },

     

       424
       424
        
         )

     

       425
       425
       +
         .post(

     

       426
       426
       +
           "/reset",

     

       427
       427
       +
           async ({ headers, set }) => {

     

       428
       428
       +
             if (headers.authorization !== `Bearer ${process.env.BEARER_TOKEN}`) {

     

       429
       429
       +
               set.status = 401;

     

       430
       430
       +
               return "Unauthorized";

     

       431
       431
       +
             }

     

       432
       432
       +
       

     

       433
       433
       +
             return await cache.purgeAll();

     

       434
       434
       +
           },

     

       435
       435
       +
           {

     

       436
       436
       +
             tags: ["The Cache!"],

     

       437
       437
       +
             headers: t.Object({

     

       438
       438
       +
               authorization: t.String({

     

       439
       439
       +
                 default: "Bearer <token>",

     

       440
       440
       +
               }),

     

       441
       441
       +
             }),

     

       442
       442
       +
             response: {

     

       443
       443
       +
               200: t.Object({

     

       444
       444
       +
                 message: t.String(),

     

       445
       445
       +
                 users: t.Number(),

     

       446
       446
       +
                 emojis: t.Number(),

     

       447
       447
       +
               }),

     

       448
       448
       +
               401: t.String({ default: "Unauthorized" }),

     

       449
       449
       +
             },

     

       450
       450
       +
           },

     

       451
       451
       +
         )

     

       425
       452
        
         .listen(process.env.PORT ?? 3000);

     

       426
       453
        
       

     

       427
       454
        
       console.log(