feat: neo4j connector #539
Merged
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
neo4j.datasource.config.mp4 |
Doc example{
"_index": "coco_document-v2",
"_type": "_doc",
"_id": "99786427481574a4b5e5d4640daf5493",
"_score": 0,
"_source": {
"id": "99786427481574a4b5e5d4640daf5493",
"payload": {
"coco_property": "2025-10-09T04:28:44.918Z",
"n": {
"category": "Legal",
"disabled": false,
"document_id": "doc-AA27",
"lang": "en",
"opened_date": "2025-09-20",
"size": 180000,
"summary": "Updated policy regarding the retention and deletion of client data.",
"title": "Data Retention Policy v2",
"type": "PDF",
"updated": "2025-10-09T04:28:44.918Z"
},
"n.disabled": false,
"n.element_id": "4:1093e8af-4022-4813-9534-8c7121ac10d4:557",
"n.labels": [
"Document"
],
"n.opened_date": "2025-09-20",
"n.updated": "2025-10-09T04:28:44.918Z"
},
"source": {
"type": "connector",
"name": "Neo4j Docs",
"id": "d3d34pdafbilvmlmnlsg"
},
"type": "PDF",
"category": "Legal",
"title": "Data Retention Policy v2",
"summary": "Updated policy regarding the retention and deletion of client data.",
"lang": "en",
"size": 180000,
"last_updated_by": {}
}
} |
medcl
reviewed
Oct 10, 2025
| Tie *StoredCursorValue `json:"tie,omitempty"` | ||
| } | ||
|
|
||
| type SyncState struct { |
There was a problem hiding this comment.
I noticed there’s a sync state management feature — that’s great to have. I’d like to extend this concept to the generic connector management infrastructure, so other connectors can also benefit from it.
I’m working on integrating existing connectors into the processor layer and leveraging the generic pipeline framework to unify data processing capabilities — stay tuned!
- Resolved conflicts in web frontend files - Merged connector types from both branches - Added Neo4j, Feishu, and Lark to supported types - All connector refactoring work preserved from both branches 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <[email protected]>
|
medcl
reviewed
Oct 22, 2025
config/setup/zh-CN/connector.tpl
Outdated
| "default" : "/assets/icons/connector/neo4j/icon.png" | ||
| } | ||
| }, | ||
| "builtin": true |
medcl
reviewed
Oct 22, 2025
coco.yml
Outdated
| interval: 30s | ||
| queue: | ||
| name: indexing_documents | ||
| neo4j: |
There was a problem hiding this comment.
this is not necessary needed anymore.
medcl
reviewed
Oct 22, 2025
| Enable the connector in `coco.yml` so coco-server can schedule sync jobs: | ||
|
|
||
| ```yaml | ||
| connector: |
medcl
reviewed
Oct 22, 2025
|
|
||
| | **Field** | **Type** | **Description** | | ||
| |--------------|-----------|------------------------------------------------------------------------------------------| | ||
| | `enabled` | `boolean` | Turns the Neo4j connector on or off. | |
There was a problem hiding this comment.
this config section is not needed any more.
medcl
reviewed
Oct 22, 2025
| ormCtx := orm.NewContextWithParent(ctx) | ||
| state := &SyncState{} | ||
| state.SetID(makeSyncStateID(connectorID, datasourceID)) | ||
| exists, err := orm.GetV2(ormCtx, state) |
There was a problem hiding this comment.
need to add ctx.DirectAccess() for load and save function, as they are background jobs.
medcl
approved these changes
Oct 23, 2025
RainyNight9
approved these changes
Oct 23, 2025
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
3 participants
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
What does this PR do
feat: neo4j connector
Standards checklist