Advertisement
WalshyDev

CDN with B2 + CF Workers

Mar 3rd, 2021 (edited)
575
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. 'use strict';
  2.  
  3. const b2Url = 'https://f002.backblazeb2.com';
  4. const b2Bucket = 'BUCKET_NAME';
  5.  
  6. const b2UrlPath = `/file/${b2Bucket}/`;
  7. addEventListener('fetch', event => {
  8.     return event.respondWith(fileReq(event));
  9. });
  10.  
  11. // define the file extensions we wish to add basic access control headers to
  12. const corsFileTypes = ['png', 'jpg', 'gif', 'jpeg', 'webp'];
  13.  
  14. // backblaze returns some additional headers that are useful for debugging, but unnecessary in production. We can remove these to save some size
  15. const removeHeaders = [
  16.     'x-bz-content-sha1',
  17.     'x-bz-file-id',
  18.     'x-bz-file-name',
  19.     'x-bz-info-src_last_modified_millis',
  20.     'X-Bz-Upload-Timestamp',
  21.     'x-bz-info-user',
  22.     'Expires'
  23. ];
  24. const expiration = 31536000; // override browser cache for images - 1 year
  25.  
  26. // define a function we can re-use to fix headers
  27. const fixHeaders = function(url, status, headers){
  28.     let newHdrs = new Headers(headers);
  29.     // add basic cors headers for images
  30.     if (corsFileTypes.includes(url.pathname.split('.').pop())) {
  31.         newHdrs.set('Access-Control-Allow-Origin', '*');
  32.     }
  33.     // override browser cache for files when 200
  34.     if (status === 200) {
  35.         newHdrs.set('Cache-Control', "public, max-age=" + expiration);
  36.     } else {
  37.         // only cache other things for 5 minutes
  38.         newHdrs.set('Cache-Control', 'public, max-age=300');
  39.     }
  40.     // set ETag for efficient caching where possible
  41.     const ETag = newHdrs.get('x-bz-content-sha1') || newHdrs.get('x-bz-info-src_last_modified_millis') || newHdrs.get('x-bz-file-id');
  42.     if (ETag) {
  43.         newHdrs.set('ETag', ETag);
  44.     }
  45.     // remove unnecessary headers
  46.     removeHeaders.forEach(header => {
  47.         newHdrs.delete(header);
  48.     });
  49.     return newHdrs;
  50. };
  51.  
  52. async function fileReq(event) {
  53.     const cache = caches.default; // Cloudflare edge caching
  54.     const url = new URL(event.request.url);
  55.  
  56.     let response = await cache.match(url); // try to find match for this request in the edge cache
  57.    
  58.     if (response) {
  59.         // use cache found on Cloudflare edge. Set X-Worker-Cache header for helpful debug
  60.         let newHdrs = fixHeaders(url, response.status, response.headers);
  61.         newHdrs.set('X-Worker-Cache', "true");
  62.         return new Response(response.body, {
  63.             status: response.status,
  64.             statusText: response.statusText,
  65.             headers: newHdrs
  66.         });
  67.     }
  68.  
  69.     // no cache, fetch image, apply Cloudflare lossless compression
  70.     response = await fetch(b2Url + '/file/' + b2Bucket + url.pathname,
  71.         {cf: {polish: "lossless"}}
  72.     );
  73.     let newHdrs = fixHeaders(url, response.status, response.headers);
  74.     response = new Response(response.body, {
  75.         status: response.status,
  76.         statusText: response.statusText,
  77.         headers: newHdrs
  78.     });
  79.  
  80.     event.waitUntil(cache.put(url, response.clone()));
  81.     return response;
  82. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement