| 6191 | } |
| 6192 | |
| 6193 | static void RedisGearsPy_SendReqMetaData(RedisModuleCtx *ctx, PythonRequirementCtx* req){ |
| 6194 | RedisModule_ReplyWithArray(ctx, 18); |
| 6195 | |
| 6196 | RedisModule_ReplyWithCString(ctx, "GearReqVersion"); |
| 6197 | RedisModule_ReplyWithLongLong(ctx, PY_REQ_VERSION); |
| 6198 | |
| 6199 | RedisModule_ReplyWithCString(ctx, "Name"); |
| 6200 | RedisModule_ReplyWithCString(ctx, req->installName); |
| 6201 | |
| 6202 | RedisModule_ReplyWithCString(ctx, "IsDownloaded"); |
| 6203 | RedisModule_ReplyWithCString(ctx, req->isDownloaded ? "yes" : "no"); |
| 6204 | |
| 6205 | RedisModule_ReplyWithCString(ctx, "IsInstalled"); |
| 6206 | RedisModule_ReplyWithCString(ctx, req->isInstalled ? "yes" : "no"); |
| 6207 | |
| 6208 | RedisModule_ReplyWithCString(ctx, "CompiledOs"); |
| 6209 | RedisModule_ReplyWithCString(ctx, RedisGears_GetCompiledOs()); |
| 6210 | |
| 6211 | RedisModule_ReplyWithCString(ctx, "Wheels"); |
| 6212 | if(req->isDownloaded){ |
| 6213 | RedisModule_ReplyWithArray(ctx, array_len(req->wheels)); |
| 6214 | for(size_t i = 0 ; i < array_len(req->wheels) ; ++i){ |
| 6215 | RedisModule_ReplyWithCString(ctx, req->wheels[i]); |
| 6216 | } |
| 6217 | }else{ |
| 6218 | RedisModule_ReplyWithCString(ctx, "Requirement was not yet downloaded so wheels are not available"); |
| 6219 | } |
| 6220 | |
| 6221 | RedisModule_ReplyWithCString(ctx, "Path"); |
| 6222 | RedisModule_ReplyWithCString(ctx, req->basePath); |
| 6223 | |
| 6224 | RedisModule_ReplyWithCString(ctx, "RefCount"); |
| 6225 | RedisModule_ReplyWithLongLong(ctx, req->refCount); |
| 6226 | |
| 6227 | RedisModule_ReplyWithCString(ctx, "IsInReqDictionary"); |
| 6228 | RedisModule_ReplyWithCString(ctx, req->isInRequirementsDict ? "yes" : "no"); |
| 6229 | } |
| 6230 | |
| 6231 | |
| 6232 | static void RedisGearsPy_DoneImportRequirement(ExecutionPlan* ep, void* privateData){ |
no test coverage detected