Updated integration to work with Notion API version 2025-09-03 (#18)

Author: NikkelM

README.md

@@ -67,6 +67,18 @@ The ID of the database you want to run the integration on. You can find the ID i
 | `string` | `""` | A valid Notion database ID | Yes |
 </details>
 
+<details>
+<summary><code>notionDataSourceId</code></summary>
+
+The ID of the data source you want to run the integration on. This is required if you have multiple data sources in your database. You can find the ID under the `Manage data sources` menu in the database settings. If you only have one data source (which is the default), you can leave this property empty.
+
+<img src="images/CopyDataSourceId.png" alt="Notion data source ID location" style="height:600px;">
+
+| Type | Default value | Possible values | Required |
+|---|---|---|---|
+| `string` | `""` | A valid data source ID of one of the data sources in your database | Yes, if you have multiple data sources in your database. |
+</details>
+
 <details>
 <summary><code>inputFile</code></summary>
 

config.default.json

@@ -2,6 +2,7 @@
 	"$schema": "config.schema.json",
 	"notionIntegrationKey": "",
 	"notionDatabaseId": "",
+	"notionDataSourceId": "",
 	"inputFile": "input.json",
 	"skipExisting": {
 		"enabled": false,

config.schema.json

@@ -20,6 +20,11 @@
 			"type": "string",
 			"default": ""
 		},
+		"notionDataSourceId": {
+			"description": "The ID of the data source you want to run the integration on. This is required if you have multiple data sources in your database. You can find the ID under the \"Manage data sources\" menu in the database settings. If you only have one data source (which is the default), you can leave this property empty.",
+			"type": "string",
+			"default": ""
+		},
 		"inputFile": {
 			"description": "The JSON file to import to Notion.",
 			"type": "string",

images/CopyDataSourceId.png

@@ -7,13 +7,15 @@ const NOTION = new Client({
 	auth: CONFIG.notionIntegrationKey,
 	logLevel: LogLevel.ERROR
 });
-const databaseId = CONFIG.notionDatabaseId;
+const DATABASE_ID = CONFIG.notionDatabaseId;
+// Will be set to the only available data source if none is provided in the config and only one exists in the database
+let DATASOURCE_ID = CONFIG.notionDataSourceId || null;
 
 export async function createNotionPage(properties) {
 	// Create a new page in the database
 	await NOTION.pages.create({
 		parent: {
-			database_id: databaseId
+			data_source_id: DATASOURCE_ID
 		},
 		properties: properties.properties,
 		cover: properties.cover,
@@ -79,8 +81,24 @@ export async function checkNotionPropertiesExistence() {
 		}
 	}
 
-	const response = await NOTION.databases.retrieve({
-		database_id: databaseId
+	const databaseResponse = await NOTION.databases.retrieve({
+		database_id: DATABASE_ID
+	});
+
+	if (CONFIG.notionDataSourceId) {
+		if (databaseResponse.data_sources.find(ds => ds.id === CONFIG.notionDataSourceId) === undefined) {
+			console.error("Error validating configuration file: Notion database does not contain a data source with the ID specified in the configuration file. Check the \"notionDataSourceId\" property in your config.json");
+			process.exit(1);
+		}
+	} else if (databaseResponse.data_sources.length == 1) {
+		DATASOURCE_ID = databaseResponse.data_sources[0].id;
+	} else {
+		console.error("Error validating configuration file: Notion database contains multiple data sources, but no data source ID to use is specified in the configuration file. Provide the \"notionDataSourceId\" property in your config.json");
+		process.exit(1);
+	}
+
+	const response = await NOTION.dataSources.retrieve({
+		data_source_id: DATASOURCE_ID
 	});
 
 	// If any of the properties are not found in the database, exit the program
@@ -181,8 +199,8 @@ export async function getExistingPagesFromNotionDatabase() {
 
 // Fetch all pages from the database that have the specified property set to anything but null
 async function queryDatabase(cursor) {
-	return await NOTION.databases.query({
-		database_id: databaseId,
+	return await NOTION.dataSources.query({
+		data_source_id: DATASOURCE_ID,
 		page_size: 100,
 		start_cursor: cursor,
 		filter: {

js/notion.js

@@ -1,15 +1,15 @@
 {
 	"name": "json-to-notion",
 	"type": "module",
-	"version": "1.2.0",
+	"version": "1.3.0",
 	"description": "Utility that is able to \"import\" JSON files to Notion - for cases where a CSV file is simply not available, and the conversion from JSON to CSV would be too complicated.",
 	"author": {
 		"name": "Nikkel Mollenhauer",
-		"email": "nikkelm.dev@gmail.com"
+		"email": "contact@nikkelm.dev"
 	},
 	"main": "index.js",
 	"dependencies": {
-		"@notionhq/client": "^1.0.1",
+		"@notionhq/client": "^5.0.0",
 		"cli-progress": "^3.11.2",
 		"jsonschema": "^1.4.1"
 	}