Skip to content

Commit 19592ef

Browse files
committed
Add missing api tools for processes
1 parent 2845666 commit 19592ef

2 files changed

Lines changed: 420 additions & 0 deletions

File tree

src/server.ts

Lines changed: 141 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,14 @@ import {
6161
UpdateProcessSchema,
6262
DeleteProcessSchema,
6363
GetProcessVersionsSchema,
64+
PublishProcessVersionSchema,
65+
GetProcessVersionSchema,
66+
DeleteProcessVersionSchema,
67+
GetProcessVersionAliasesSchema,
68+
CreateProcessVersionAliasSchema,
69+
GetProcessVersionAliasSchema,
70+
DeleteProcessVersionAliasSchema,
71+
UpdateProcessVersionAliasSchema,
6472
ExecuteProcessAsyncSchema,
6573
ExecuteProcessSyncSchema,
6674
ScheduleProcessSchema,
@@ -748,6 +756,139 @@ class YepCodeMcpServer extends Server {
748756
}
749757
);
750758

759+
case processesToolNames.publishProcessVersion:
760+
return this.handleToolRequest(
761+
PublishProcessVersionSchema,
762+
request,
763+
async (data) => {
764+
const {
765+
processId,
766+
tag,
767+
readme,
768+
comment,
769+
sourceCode,
770+
parametersSchema,
771+
} = data;
772+
const publishData: any = {};
773+
if (tag !== undefined) publishData.tag = tag;
774+
if (readme !== undefined) publishData.readme = readme;
775+
if (comment !== undefined) publishData.comment = comment;
776+
if (sourceCode !== undefined) publishData.sourceCode = sourceCode;
777+
if (parametersSchema !== undefined)
778+
publishData.parametersSchema = parametersSchema;
779+
const version = await this.yepCodeApi.publishProcessVersion(
780+
processId,
781+
publishData
782+
);
783+
return version;
784+
}
785+
);
786+
787+
case processesToolNames.getProcessVersion:
788+
return this.handleToolRequest(
789+
GetProcessVersionSchema,
790+
request,
791+
async (data) => {
792+
const version = await this.yepCodeApi.getProcessVersion(
793+
data.processId,
794+
data.versionId
795+
);
796+
return version;
797+
}
798+
);
799+
800+
case processesToolNames.deleteProcessVersion:
801+
return this.handleToolRequest(
802+
DeleteProcessVersionSchema,
803+
request,
804+
async (data) => {
805+
await this.yepCodeApi.deleteProcessVersion(
806+
data.processId,
807+
data.versionId
808+
);
809+
return {
810+
result: `Process version ${data.versionId} deleted successfully`,
811+
};
812+
}
813+
);
814+
815+
case processesToolNames.getProcessVersionAliases:
816+
return this.handleToolRequest(
817+
GetProcessVersionAliasesSchema,
818+
request,
819+
async (data) => {
820+
const aliases = await this.yepCodeApi.getProcessVersionAliases(
821+
data.processId,
822+
{
823+
versionId: data.versionId,
824+
page: data.page,
825+
limit: data.limit,
826+
}
827+
);
828+
return aliases;
829+
}
830+
);
831+
832+
case processesToolNames.createProcessVersionAlias:
833+
return this.handleToolRequest(
834+
CreateProcessVersionAliasSchema,
835+
request,
836+
async (data) => {
837+
const { processId, ...aliasData } = data;
838+
const alias = await this.yepCodeApi.createProcessVersionAlias(
839+
processId,
840+
aliasData
841+
);
842+
return alias;
843+
}
844+
);
845+
846+
case processesToolNames.getProcessVersionAlias:
847+
return this.handleToolRequest(
848+
GetProcessVersionAliasSchema,
849+
request,
850+
async (data) => {
851+
const alias = await this.yepCodeApi.getProcessVersionAlias(
852+
data.processId,
853+
data.aliasId
854+
);
855+
return alias;
856+
}
857+
);
858+
859+
case processesToolNames.deleteProcessVersionAlias:
860+
return this.handleToolRequest(
861+
DeleteProcessVersionAliasSchema,
862+
request,
863+
async (data) => {
864+
await this.yepCodeApi.deleteProcessVersionAlias(
865+
data.processId,
866+
data.aliasId
867+
);
868+
return {
869+
result: `Process version alias ${data.aliasId} deleted successfully`,
870+
};
871+
}
872+
);
873+
874+
case processesToolNames.updateProcessVersionAlias:
875+
return this.handleToolRequest(
876+
UpdateProcessVersionAliasSchema,
877+
request,
878+
async (data) => {
879+
const { processId, aliasId, name, versionId } = data;
880+
const updateData: any = {};
881+
if (name !== undefined) updateData.name = name;
882+
if (versionId !== undefined) updateData.versionId = versionId;
883+
const alias = await this.yepCodeApi.updateProcessVersionAlias(
884+
processId,
885+
aliasId,
886+
updateData
887+
);
888+
return alias;
889+
}
890+
);
891+
751892
case processesToolNames.executeProcessAsync:
752893
return this.handleToolRequest(
753894
ExecuteProcessAsyncSchema,

0 commit comments

Comments
 (0)