Updates most examples to data sources

Author: typeoneerror

examples/architect-os/update-dates.js

@@ -73,8 +73,9 @@ function validDateConfig(part, defaultValue = 1) {
     console.log(`Updating ${dbTitle} dates (${id})...`);
 
     const database = await notion.databases.retrieve({ database_id: id });
+    const dataSource = database.data_sources.at(0);
     const query = filter ? { filter } : null;
-    const pages = await fetchAllPages(id, query);
+    const pages = await fetchAllPages(dataSource.id, query);
 
     const sortedPages = pages.sort((a, b) => {
       return getDate(a, dateProp) - getDate(b, dateProp);

examples/data-sources/update/index.js

@@ -0,0 +1,42 @@
+/**
+ * Update a data source.
+ *
+ * This example updates a formula, renames the data source, and switches an icon.
+ *
+ * Arguments:
+ *
+ * --data-source-id: ID of the database to update
+ * --prop-id: ID of property to update
+ * --title: Title of the data source to change to
+ */
+
+const { notion, yargs } = require('../../shared');
+const props = require('../../shared/props');
+const { log } = require('../../shared/utils');
+
+const dataSourceId = 'bb23cc5b-70e1-4b11-ad4c-d92a97c43717';
+const title = 'Updated Data Source Name';
+const propId = 'f%5Csj';
+const argv = yargs.default({ dataSourceId, propId, title }).argv;
+
+const properties = {
+  [argv.propId]: {
+    name: 'X * Y',
+    formula: {
+      expression: 'prop("X") * prop("Y")',
+    },
+  },
+};
+
+const params = {
+  data_source_id: argv.dataSourceId,
+  icon: props.emoji('🐞'),
+  title: [props.text(argv.title)],
+  properties,
+};
+
+(async () => {
+  const dataSource = await notion.dataSources.update(params);
+
+  log(dataSource);
+})();

examples/databases/bulk-edit/changelog.js

@@ -51,7 +51,9 @@ async function editPage(page) {
 }
 
 (async () => {
-  const pages = await fetchAllPages(databaseId);
+  const database = await notion.databases.retrieve({ database_id: databaseId });
+  const dataSource = database.data_sources.at(0);
+  const pages = await fetchAllPages(dataSource.id);
 
   await performWithAll(pages, editPage);
 })();

examples/databases/bulk-edit/index.js

@@ -64,7 +64,9 @@ async function editPage(page) {
 }
 
 (async () => {
-  const pages = await fetchAllPages(argv.databaseId, {
+  const database = await notion.databases.retrieve({ database_id: argv.databaseId });
+  const dataSource = database.data_sources.at(0);
+  const pages = await fetchAllPages(dataSource.id, {
     filter: {
       or: [
         {

examples/databases/bulk-edit/spends-and-trends.js

@@ -1,4 +1,7 @@
 /**
+ * Note: this uses an older version of the Notion API which used Databases
+ * APIs instead of the newer Data Sources APIs.
+ *
  * Example bulk-edit script. In this script, there are two databases. One is
  * Spends which has a bunch of data for advertising spends in it. The other
  * is Trends, which has a bunch of data for traffic/metrics for websites. There
@@ -32,7 +35,6 @@ async function editPage(page) {
   const dateTitle = format(parsed, 'MMM d, yyyy');
   const spendsTitle = `Spends: ${dateTitle}`;
 
-  // FIXME: use data sources
   const {
     results: [spends],
   } = await notion.databases.query({

examples/databases/search/index.js

@@ -11,10 +11,10 @@
 const { notion, yargs } = require('../../shared');
 const { log } = require('../../shared/utils');
 
-const databaseId = '7354557becb34d72b6140bb541ac529a';
+const dataSourceId = '668bd2e3-9307-4438-83b5-75b11376e8a3';
 
 const argv = yargs.default({
-  databaseId,
+  dataSourceId,
   query: '',
   pageSize: 100,
 }).argv;
@@ -23,9 +23,8 @@ const argv = yargs.default({
 // that contains the text "Hall". This is a non-exact match, so would find:
 // "Hall of Fame" and "Hall 1 Lighting".
 (async () => {
-  // FIXME: use data sources
-  const response = await notion.databases.query({
-    database_id: argv.databaseId,
+  const response = await notion.dataSources.query({
+    data_source_id: argv.dataSourceId,
     query: argv.query,
     filter: {
       property: 'Task',

examples/databases/sort-multi-select/index.js

@@ -1,9 +1,11 @@
 /**
  * Sort a multi-select's options alphabetically.
  *
+ * Note: you can only sort up to 100 options like this!
+ *
  * Arguments:
  *
- * --database-id: ID of the database to create in
+ * --data-source-id: ID of the database to create in
  * --sort-prop: name of multi-select to sort
  * --[no-]case-sensitive: whether to sort ABCabc (default or --case-sensitive) or AaBbCc (--no-case-sensitive)
  */
@@ -12,30 +14,30 @@ const { notion, yargs } = require('../../shared');
 const { log } = require('../../shared/utils');
 const _ = require('lodash');
 
-const databaseId = 'f91e66f29d63457894be7c91b132f345';
+const dataSourceId = '1cf71d94-0107-4560-a702-a41cb5d90aea';
 const sortProp = 'Feeling';
 const argv = yargs
   .boolean('case-sensitive')
-  .default({ databaseId, sortProp, caseSensitive: true }).argv;
+  .default({ dataSourceId, sortProp, caseSensitive: true }).argv;
 
 (async () => {
-  let database = await notion.databases.retrieve({
-    database_id: argv.databaseId,
+  let dataSource = await notion.dataSources.retrieve({
+    data_source_id: argv.dataSourceId,
   });
 
-  const propId = database.properties[argv.sortProp].id;
+  const propId = dataSource.properties[argv.sortProp].id;
   const iteratee = argv.caseSensitive ? 'name' : [(option) => option.name.toLowerCase()];
 
   // Sort the options and remove color since it cannot be updated via API
   const sortedOptions = _.map(
-    _.orderBy(database.properties[argv.sortProp].multi_select.options, iteratee),
+    _.orderBy(dataSource.properties[argv.sortProp].multi_select.options, iteratee),
     (option) => {
       return _.omit(option, 'color');
     }
   );
 
   const properties = {
-    database_id: argv.databaseId,
+    data_source_id: argv.dataSourceId,
     properties: {
       [propId]: {
         multi_select: {
@@ -45,8 +47,7 @@ const argv = yargs
     },
   };
 
-  // FIXME: use data sources
-  database = await notion.databases.update(properties);
+  dataSource = await notion.dataSources.update(properties);
 
-  log(database.properties[argv.sortProp]);
+  log(dataSource.properties[argv.sortProp]);
 })();

examples/databases/update/index.js

@@ -1,7 +1,7 @@
 /**
  * Update a database.
  *
- * This example updates a formula, renames the database, and switches an icon.
+ * This example renames the database and switches an icon.
  *
  * Works great when used with the database created with the ../create script!
  *
@@ -34,11 +34,9 @@ const params = {
   database_id: argv.databaseId,
   icon: props.emoji('💽'),
   title: [props.text(argv.title)],
-  properties,
 };
 
 (async () => {
-  // FIXME: use data sources
   const database = await notion.databases.update(params);
 
   log(database);

examples/formula1/circuits.js

@@ -1,4 +1,3 @@
-// FIXME: Data Sources
 const orderBy = require('lodash/orderBy');
 const { RateLimit } = require('async-sema');
 
@@ -15,6 +14,10 @@ const limit = RateLimit(1, { timeUnit: 2000, uniformDistribution: true });
 async function createCircuitsDatabase() {
   const response = await notion.search({
     query: DB_TITLE,
+    filter: {
+      value: 'data_source',
+      property: 'object',
+    },
   });
 
   if (response.results.length) {
@@ -57,7 +60,7 @@ async function fetchCircuits() {
   return orderBy(circuits, 'circuitName', 'desc');
 }
 
-async function createCircuit(database, circuit) {
+async function createCircuit(dataSource, circuit) {
   process.stdout.write('.');
 
   const {
@@ -76,7 +79,7 @@ async function createCircuit(database, circuit) {
 
   return await notion.pages.create({
     parent: {
-      database_id: database.id,
+      data_source_id: dataSource.id,
     },
     properties,
   });
@@ -85,10 +88,12 @@ async function createCircuit(database, circuit) {
 async function createCircuits(database, circuits) {
   process.stdout.write('Creating circuits...');
 
+  const dataSource = database.data_sources.at(0);
+
   return await Promise.all(
     circuits.map(async (circuit) => {
       await limit();
-      return await createCircuit(database, circuit);
+      return await createCircuit(dataSource, circuit);
     })
   );
 }

examples/nm/align-member-ids.js

@@ -50,8 +50,10 @@ async function updateStudent(page, users) {
 
 (async () => {
   const users = await getCache('members');
+  const database = await notion.databases.retrieve({ database_id: studentsDbId });
+  const dataSource = database.data_sources.at(0);
 
-  const pages = await fetchAllPages(studentsDbId, {
+  const pages = await fetchAllPages(dataSource.id, {
     filter: {
       and: [
         {