SKU/molecule

CHANGELOG.md

@@ -12,8 +12,17 @@ Recommendation: for ease of reading, use the following order:
 -->
 
 ## [Unreleased]
+### Added
+- GQL: `BigInt` scalar
 ### Changed
+- GQL: `molecule` area: use `BigInt` for `ipnft_token_id` 
+- Allow `molecule` and `molecule.dev` accounts separation
+- Collection datasets will ignore add and move operations that don't change the entry path, ref, or extra attributes and return `CollectionUpdateUpToDate`
+- GQL: `Search::query()`: case insensitive search.
+- GQL: `MoleculeMut::create_project()`: generate lowercase project account name.
 - Discontinued binary releases for MacOS Intel architecture (see #1323) and Windows (as we only ever supported WSL2)
+### Fixed
+- Investigation: potential unstable ordering of dataset entry listings
 
 ## [0.249.1] - 2025-09-25
 ### Fixed

resources/schema.gql

@@ -474,6 +474,11 @@ Base64-encoded binary data (url-safe, no padding)
 """
 scalar Base64Usnp
 
+"""
+A big integer scalar type.
+"""
+scalar BigInt
+
 type BlockRef {
 	name: String!
 	blockHash: Multihash!
@@ -795,6 +800,25 @@ type CreateAccountSuccess implements CreateAccountResult {
 	message: String!
 }
 
+type CreateAnnouncementErrorInvalidAttachment implements CreateAnnouncementResult {
+	message: String!
+	isSuccess: Boolean!
+}
+
+interface CreateAnnouncementResult {
+	isSuccess: Boolean!
+	message: String!
+}
+
+type CreateAnnouncementSuccess implements CreateAnnouncementResult {
+	"""
+	ID of the newly-created announcement
+	"""
+	announcementId: String!
+	isSuccess: Boolean!
+	message: String!
+}
+
 interface CreateDatasetFromSnapshotResult {
 	isSuccess: Boolean!
 	message: String!
@@ -829,6 +853,23 @@ type CreateDatasetResultSuccess implements CreateDatasetResult & CreateDatasetFr
 	message: String!
 }
 
+type CreateProjectErrorConflict implements CreateProjectResult {
+	project: MoleculeProject!
+	isSuccess: Boolean!
+	message: String!
+}
+
+interface CreateProjectResult {
+	isSuccess: Boolean!
+	message: String!
+}
+
+type CreateProjectSuccess implements CreateProjectResult {
+	project: MoleculeProject!
+	isSuccess: Boolean!
+	message: String!
+}
+
 interface CreateTokenResult {
 	message: String!
 }
@@ -2570,6 +2611,11 @@ input InitiatorFilterInput @oneOf {
 	accounts: [AccountID!]
 }
 
+"""
+A scalar that can represent any JSON value.
+"""
+scalar JSON
+
 type JdbcDesc {
 	url: String!
 }
@@ -2820,6 +2866,190 @@ type ModifyPasswordWrongOldPassword implements ModifyPasswordResult {
 	message: String!
 }
 
+type Molecule {
+	"""
+	Looks up the project
+	"""
+	project(ipnftUid: String!): MoleculeProject
+	"""
+	List the registered projects
+	"""
+	projects(page: Int, perPage: Int): MoleculeProjectConnection!
+	"""
+	Latest activity events across all projects in reverse chronological
+	order
+	"""
+	activity(page: Int, perPage: Int): MoleculeProjectEventConnection!
+}
+
+type MoleculeMut {
+	createProject(ipnftSymbol: String!, ipnftUid: String!, ipnftAddress: String!, ipnftTokenId: U256!): CreateProjectResult!
+	"""
+	Looks up the project
+	"""
+	project(ipnftUid: String!): MoleculeProjectMut
+}
+
+type MoleculeProject {
+	"""
+	System time when this version was created/updated
+	"""
+	systemTime: DateTime!
+	"""
+	Event time when this version was created/updated
+	"""
+	eventTime: DateTime!
+	"""
+	Symbolic name of the project
+	"""
+	ipnftSymbol: String!
+	"""
+	Unique ID of the IPNFT as `{ipnftAddress}_{ipnftTokenId}`
+	"""
+	ipnftUid: String!
+	"""
+	Address of the IPNFT contract
+	"""
+	ipnftAddress: String!
+	"""
+	Token ID withing the IPNFT contract
+	"""
+	ipnftTokenId: BigInt!
+	"""
+	Project's organizational account
+	"""
+	account: Account!
+	"""
+	Project's data room dataset
+	"""
+	dataRoom: Dataset!
+	"""
+	Project's announcements dataset
+	"""
+	announcements: Dataset!
+	"""
+	Project's activity events in reverse chronological order
+	"""
+	activity(page: Int, perPage: Int): MoleculeProjectEventConnection!
+}
+
+type MoleculeProjectConnection {
+	"""
+	A shorthand for `edges { node { ... } }`
+	"""
+	nodes: [MoleculeProject!]!
+	"""
+	Approximate number of total nodes
+	"""
+	totalCount: Int!
+	"""
+	Page information
+	"""
+	pageInfo: PageBasedInfo!
+	edges: [MoleculeProjectEdge!]!
+}
+
+type MoleculeProjectEdge {
+	node: MoleculeProject!
+}
+
+interface MoleculeProjectEvent {
+	project: MoleculeProject!
+	systemTime: DateTime!
+}
+
+type MoleculeProjectEventAnnouncement implements MoleculeProjectEvent {
+	"""
+	Associated project
+	"""
+	project: MoleculeProject!
+	"""
+	Announcement record
+	"""
+	announcement: JSON!
+	systemTime: DateTime!
+}
+
+type MoleculeProjectEventConnection {
+	"""
+	A shorthand for `edges { node { ... } }`
+	"""
+	nodes: [MoleculeProjectEvent!]!
+	"""
+	Page information
+	"""
+	pageInfo: PageBasedInfo!
+	edges: [MoleculeProjectEventEdge!]!
+}
+
+type MoleculeProjectEventDataRoomEntryAdded implements MoleculeProjectEvent {
+	"""
+	Associated project
+	"""
+	project: MoleculeProject!
+	"""
+	Collection entry
+	"""
+	entry: CollectionEntry!
+	systemTime: DateTime!
+}
+
+type MoleculeProjectEventDataRoomEntryRemoved implements MoleculeProjectEvent {
+	"""
+	Associated project
+	"""
+	project: MoleculeProject!
+	"""
+	Collection entry
+	"""
+	entry: CollectionEntry!
+	systemTime: DateTime!
+}
+
+type MoleculeProjectEventDataRoomEntryUpdated implements MoleculeProjectEvent {
+	"""
+	Associated project
+	"""
+	project: MoleculeProject!
+	"""
+	Collection entry
+	"""
+	newEntry: CollectionEntry!
+	systemTime: DateTime!
+}
+
+type MoleculeProjectEventEdge {
+	node: MoleculeProjectEvent!
+}
+
+type MoleculeProjectEventFileUpdated implements MoleculeProjectEvent {
+	"""
+	Associated project
+	"""
+	project: MoleculeProject!
+	"""
+	Versioned file dataset
+	"""
+	dataset: Dataset!
+	"""
+	New file version entry
+	"""
+	newEntry: VersionedFileEntry!
+	systemTime: DateTime!
+}
+
+type MoleculeProjectMut {
+	"""
+	Creates an announcement record for the project
+	"""
+	createAnnouncement(		headline: String!,		body: String!,
+		"""
+		List of dataset DIDs to link
+		"""
+		attachments: [String!],		moleculeAccessLevel: String!,		moleculeChangeBy: String!
+	): CreateAnnouncementResult!
+}
+
 """
 MQTT quality of service class.
 
@@ -2871,6 +3101,10 @@ type Mutation {
 	"""
 	accounts: AccountsMut!
 	"""
+	Temporary: Molecule-specific functionality group
+	"""
+	molecule: MoleculeMut!
+	"""
 	Collaboration-related functionality group
 
 	Allows setting permissions for multiple datasets in batch mode
@@ -3062,6 +3296,10 @@ type Query {
 	Admin-related functionality group
 	"""
 	admin: Admin!
+	"""
+	Temporary: Molecule-specific functionality group
+	"""
+	molecule: Molecule!
 }
 
 enum QueryDialect {
@@ -3929,6 +4167,11 @@ type TriggerFlowSuccess implements TriggerFlowResult {
 	message: String!
 }
 
+"""
+256-bit unsigned number. Can be constructed from string.
+"""
+scalar U256
+
 scalar URL
 
 interface UnsetRoleResult {

src/adapter/graphql/Cargo.toml

@@ -65,6 +65,7 @@ async-graphql = { version = "7", default-features = false, features = [
 async-trait = { version = "0.1", default-features = false }
 base64 = { version = "0.22", default-features = false }
 bytes = { version = "1", default-features = false }
+num-bigint = { version = "0.4", default-features = false }
 chrono = "0.4"
 # TODO: Currently needed for type conversions but ideally should be encapsulated by kamu-core
 datafusion = { version = "50", default-features = false, features = ["serde"] }

src/adapter/graphql/src/lib.rs

@@ -28,3 +28,7 @@ pub(crate) mod utils;
 pub use config::*;
 pub use guards::*;
 pub use root::*;
+
+pub mod molecule {
+    pub use crate::queries::molecule::{Molecule, molecule_subject};
+}

src/adapter/graphql/src/mutations/mod.rs

@@ -19,6 +19,7 @@ mod dataset_mut;
 mod datasets_mut;
 mod flows_mut;
 mod metadata_chain_mut;
+mod molecule_mut;
 mod webhooks_mut;
 
 pub(crate) use account_access_token_mut::*;
@@ -32,4 +33,5 @@ pub(crate) use dataset_mut::*;
 pub(crate) use datasets_mut::*;
 pub(crate) use flows_mut::*;
 pub(crate) use metadata_chain_mut::*;
+pub(crate) use molecule_mut::*;
 pub(crate) use webhooks_mut::*;