index.mjs

#!/usr/bin/env node

import { getDoc, setDoc } from "@junobuild/core";
import { getIdentity } from "./auth.mjs";
import { readFile } from "fs/promises";

const identity = getIdentity();

const readData = async () => {
  const buffer = await readFile(process.env.DATA_SRC);
  return JSON.parse(buffer.toString("utf-8"));
};

const satellite = {
  identity,
  satelliteId: process.env.JUNO_SATELLITE_ID,
};

const collection = process.env.JUNO_DATASTORE_COLLECTION;
const keyField = process.env.DATA_KEY_FIELD;

const get = async (key) =>
  getDoc({
    collection,
    key,
    satellite,
  });

const set = async (entry) => {
  const key = entry[keyField];

  console.log(`Set key ${key}: start`);

  const existingEntry = await get(key);

  await setDoc({
    collection,
    satellite,
    doc: {
      ...(existingEntry !== undefined && existingEntry),
      key,
      data: entry,
    },
  });

  console.log(`Set key ${key}: end`);
};

const loadData = async () => {
  const data = await readData();

  const promises = data.map((entry) => set(entry));
  await Promise.all(promises);
};

await loadData();

// Uncomment to list documents
// console.log("List:", await listDocs({
//     collection,
//     satellite,
//     filter: {}
// }))

console.log("Done.");