Skip to content

Commit 2725457

Browse files
committed
Merge branch 'feat/component/airweave' of https://github.com/EwanTauran/pipedream into feat/component/airweave
2 parents 8f4545a + 4aabdba commit 2725457

File tree

83 files changed

+1733
-111
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

83 files changed

+1733
-111
lines changed

components/airweave/actions/create-collection/create-collection.mjs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,11 @@ export default {
55
name: "Create Collection",
66
description: "Create a new Airweave collection. Collections are logical groups of data sources that provide unified search capabilities. The newly created collection is initially empty until you add source connections to it. [See the documentation](https://docs.airweave.ai/api-reference/collections/create)",
77
version: "0.0.1",
8+
annotations: {
9+
destructiveHint: false,
10+
openWorldHint: true,
11+
readOnlyHint: false,
12+
},
813
type: "action",
914
props: {
1015
airweave,
@@ -33,7 +38,7 @@ export default {
3338
});
3439

3540
$.export("$summary", `Successfully created collection: ${response.name} (${response.readable_id})`);
36-
41+
3742
return response;
3843
},
3944
};

components/airweave/actions/delete-collection/delete-collection.mjs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,11 @@ export default {
55
name: "Delete Collection",
66
description: "Delete a collection and all associated data. This permanently removes the collection including all synced data and source connections. This action cannot be undone. [See the documentation](https://docs.airweave.ai/api-reference/collections/delete)",
77
version: "0.0.1",
8+
annotations: {
9+
destructiveHint: true,
10+
openWorldHint: true,
11+
readOnlyHint: false,
12+
},
813
type: "action",
914
props: {
1015
airweave,
@@ -28,7 +33,7 @@ export default {
2833
const response = await this.airweave.deleteCollection(this.collectionId);
2934

3035
$.export("$summary", `Successfully deleted collection: ${response.name} (${response.readable_id})`);
31-
36+
3237
return response;
3338
},
3439
};

components/airweave/actions/get-collection/get-collection.mjs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,11 @@ export default {
55
name: "Get Collection",
66
description: "Retrieve details of a specific collection by its readable ID. [See the documentation](https://docs.airweave.ai/api-reference/collections/get)",
77
version: "0.0.1",
8+
annotations: {
9+
destructiveHint: false,
10+
openWorldHint: true,
11+
readOnlyHint: true,
12+
},
813
type: "action",
914
props: {
1015
airweave,
@@ -19,7 +24,7 @@ export default {
1924
const response = await this.airweave.getCollection(this.collectionId);
2025

2126
$.export("$summary", `Successfully retrieved collection: ${response.name} (${response.readable_id})`);
22-
27+
2328
return response;
2429
},
2530
};

components/airweave/actions/list-collections/list-collections.mjs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,11 @@ export default {
55
name: "List Collections",
66
description: "List all collections in your organization. Collections are logical groups of data sources that provide unified search capabilities. [See the documentation](https://docs.airweave.ai/api-reference/collections/list)",
77
version: "0.0.1",
8+
annotations: {
9+
destructiveHint: false,
10+
openWorldHint: true,
11+
readOnlyHint: true,
12+
},
813
type: "action",
914
props: {
1015
airweave,
@@ -34,7 +39,7 @@ export default {
3439

3540
const count = response.length;
3641
$.export("$summary", `Successfully retrieved ${count} collection(s)`);
37-
42+
3843
return response;
3944
},
4045
};

components/airweave/actions/list-sources/list-sources.mjs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,11 @@ export default {
55
name: "List Available Sources",
66
description: "List all available data source connectors. These are the types of integrations Airweave can connect to (e.g., GitHub, Slack, Google Drive, PostgreSQL, etc.). [See the documentation](https://docs.airweave.ai/api-reference/sources/list)",
77
version: "0.0.1",
8+
annotations: {
9+
destructiveHint: false,
10+
openWorldHint: true,
11+
readOnlyHint: true,
12+
},
813
type: "action",
914
props: {
1015
airweave,
@@ -14,7 +19,7 @@ export default {
1419

1520
const count = response.length;
1621
$.export("$summary", `Successfully retrieved ${count} available source connector(s)`);
17-
22+
1823
return response;
1924
},
2025
};

components/airweave/actions/search-collection/search-collection.mjs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,11 @@ export default {
55
name: "Search Collection",
66
description: "Search across all data sources within a collection using semantic and keyword search. [See the documentation](https://docs.airweave.ai/api-reference/collections/search)",
77
version: "0.0.1",
8+
annotations: {
9+
destructiveHint: false,
10+
openWorldHint: true,
11+
readOnlyHint: true,
12+
},
813
type: "action",
914
props: {
1015
airweave,
@@ -69,7 +74,7 @@ export default {
6974

7075
const resultCount = response.results?.length || 0;
7176
$.export("$summary", `Successfully searched collection "${this.collectionId}" and found ${resultCount} result(s)`);
72-
77+
7378
return response;
7479
},
7580
};

components/airweave/actions/trigger-sync/trigger-sync.mjs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,11 @@ export default {
55
name: "Trigger Source Connection Sync",
66
description: "Manually trigger a data sync for a source connection. The sync job runs asynchronously in the background and returns immediately with job details. [See the documentation](https://docs.airweave.ai/api-reference/source-connections/run)",
77
version: "0.0.1",
8+
annotations: {
9+
destructiveHint: false,
10+
openWorldHint: true,
11+
readOnlyHint: false,
12+
},
813
type: "action",
914
props: {
1015
airweave,
@@ -31,7 +36,7 @@ export default {
3136
);
3237

3338
$.export("$summary", `Successfully triggered sync job: ${response.id} (Status: ${response.status})`);
34-
39+
3540
return response;
3641
},
3742
};

components/airweave/package.json

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
{
22
"name": "@pipedream/airweave",
33
"version": "0.1.0",
4-
"description": "Pipedream Airweave Components - Make any app searchable for your agent",
4+
"description": "Pipedream Airweave Components",
55
"main": "airweave.app.mjs",
66
"keywords": [
77
"pipedream",
@@ -18,7 +18,7 @@
1818
},
1919
"homepage": "https://pipedream.com/apps/airweave",
2020
"author": "Pipedream <[email protected]> (https://pipedream.com/)",
21-
"gitHead": "main",
22-
"license": "MIT"
21+
"publishConfig": {
22+
"access": "public"
23+
}
2324
}
24-
Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
import fathom from "../../fathom.app.mjs";
2+
3+
export default {
4+
key: "fathom-get-recording-summary",
5+
name: "Get Recording Summary",
6+
description: "Get the summary of a recording. [See the documentation](https://developers.fathom.ai/api-reference/recordings/get-summary)",
7+
version: "0.0.1",
8+
type: "action",
9+
annotations: {
10+
destructiveHint: false,
11+
openWorldHint: true,
12+
readOnlyHint: true,
13+
},
14+
props: {
15+
fathom,
16+
recordingId: {
17+
propDefinition: [
18+
fathom,
19+
"recordingId",
20+
],
21+
},
22+
},
23+
async run({ $ }) {
24+
const response = await this.fathom.getRecordingSummary({
25+
$,
26+
recordingId: this.recordingId,
27+
});
28+
$.export("$summary", `Successfully fetched recording summary for recording ID: ${this.recordingId}`);
29+
return response;
30+
},
31+
};
Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
import fathom from "../../fathom.app.mjs";
2+
3+
export default {
4+
key: "fathom-get-recording-transcript",
5+
name: "Get Recording Transcript",
6+
description: "Get the transcript of a recording. [See the documentation](https://developers.fathom.ai/api-reference/recordings/get-transcript)",
7+
version: "0.0.1",
8+
type: "action",
9+
annotations: {
10+
destructiveHint: false,
11+
openWorldHint: true,
12+
readOnlyHint: true,
13+
},
14+
props: {
15+
fathom,
16+
recordingId: {
17+
propDefinition: [
18+
fathom,
19+
"recordingId",
20+
],
21+
},
22+
},
23+
async run({ $ }) {
24+
const response = await this.fathom.getRecordingTranscript({
25+
$,
26+
recordingId: this.recordingId,
27+
});
28+
$.export("$summary", `Successfully fetched recording transcript for recording ID: ${this.recordingId}`);
29+
return response;
30+
},
31+
};

0 commit comments

Comments
 (0)