({
memory,
documents,
account
}: {
memory: MemoryI;
documents: MemoryDocumentI[];
account: Account;
})
| 1034 | } |
| 1035 | |
| 1036 | async function overwriteMemory({ |
| 1037 | memory, |
| 1038 | documents, |
| 1039 | account |
| 1040 | }: { |
| 1041 | memory: MemoryI; |
| 1042 | documents: MemoryDocumentI[]; |
| 1043 | account: Account; |
| 1044 | }): Promise<void> { |
| 1045 | p.log.message( |
| 1046 | `Overwriting memory "${memory.name}" in prod at Langbase.com with local documents.` |
| 1047 | ); |
| 1048 | |
| 1049 | // Delete old memory. |
| 1050 | dlog(`Deleting old memory: ${memory.name}`); |
| 1051 | const { deleteMemory } = getMemoryApiUrls({ |
| 1052 | memoryName: memory.name |
| 1053 | }); |
| 1054 | |
| 1055 | // Wait 500 ms to avoid rate limiting |
| 1056 | await new Promise(resolve => setTimeout(resolve, 500)); |
| 1057 | const deleteResponse = await fetch(deleteMemory, { |
| 1058 | method: 'DELETE', |
| 1059 | headers: { |
| 1060 | Authorization: `Bearer ${account.apiKey}` |
| 1061 | } |
| 1062 | }); |
| 1063 | |
| 1064 | if (!deleteResponse.ok) { |
| 1065 | const error = await deleteResponse.text(); |
| 1066 | throw new Error( |
| 1067 | `HTTP error! status: ${deleteResponse.status}, message: ${error}` |
| 1068 | ); |
| 1069 | } |
| 1070 | |
| 1071 | p.log.message(`Overwriting memory: ${memory.name}`); |
| 1072 | |
| 1073 | // Reuse same function to create the memory. |
| 1074 | await new Promise(resolve => setTimeout(resolve, 1000)); |
| 1075 | await upsertMemory({ |
| 1076 | memory, |
| 1077 | documents, |
| 1078 | account, |
| 1079 | overwrite: true |
| 1080 | }); |
| 1081 | } |
| 1082 | |
| 1083 | export async function handleGitSyncMemoryDeploy({ |
| 1084 | memory, |
no test coverage detected