PythonBindings.cpp 50 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372
  1. /*
  2. * Copyright (c) Contributors to the Open 3D Engine Project.
  3. * For complete copyright and license terms please see the LICENSE at the root of this distribution.
  4. *
  5. * SPDX-License-Identifier: Apache-2.0 OR MIT
  6. *
  7. */
  8. #include <PythonBindings.h>
  9. #include <ProjectManagerDefs.h>
  10. // Qt defines slots, which interferes with the use here.
  11. #pragma push_macro("slots")
  12. #undef slots
  13. #include <pybind11/functional.h>
  14. #include <pybind11/embed.h>
  15. #include <pybind11/eval.h>
  16. #include <pybind11/stl.h>
  17. #pragma pop_macro("slots")
  18. #include <AzCore/IO/FileIO.h>
  19. #include <AzCore/IO/SystemFile.h>
  20. #include <AzCore/std/containers/unordered_set.h>
  21. #include <AzCore/std/string/conversions.h>
  22. #include <AzCore/std/numeric.h>
  23. #include <AzCore/StringFunc/StringFunc.h>
  24. #include <QDir>
  25. namespace Platform
  26. {
  27. bool InsertPythonLibraryPath(
  28. AZStd::unordered_set<AZStd::string>& paths, const char* pythonPackage, const char* engineRoot, const char* subPath)
  29. {
  30. // append lib path to Python paths
  31. AZ::IO::FixedMaxPath libPath = engineRoot;
  32. libPath /= AZ::IO::FixedMaxPathString::format(subPath, pythonPackage);
  33. libPath = libPath.LexicallyNormal();
  34. if (AZ::IO::SystemFile::Exists(libPath.c_str()))
  35. {
  36. paths.insert(libPath.c_str());
  37. return true;
  38. }
  39. AZ_Warning("python", false, "Python library path should exist. path:%s", libPath.c_str());
  40. return false;
  41. }
  42. // Implemented in each different platform's PAL implementation files, as it differs per platform.
  43. AZStd::string GetPythonHomePath(const char* pythonPackage, const char* engineRoot);
  44. } // namespace Platform
  45. #define Py_To_String(obj) pybind11::str(obj).cast<std::string>().c_str()
  46. #define Py_To_String_Optional(dict, key, default_string) dict.contains(key) ? Py_To_String(dict[key]) : default_string
  47. #define Py_To_Int(obj) obj.cast<int>()
  48. #define Py_To_Int_Optional(dict, key, default_int) dict.contains(key) ? Py_To_Int(dict[key]) : default_int
  49. #define QString_To_Py_String(value) pybind11::str(value.toStdString())
  50. #define QString_To_Py_Path(value) m_pathlib.attr("Path")(value.toStdString())
  51. namespace RedirectOutput
  52. {
  53. using RedirectOutputFunc = AZStd::function<void(const char*)>;
  54. struct RedirectOutput
  55. {
  56. PyObject_HEAD RedirectOutputFunc write;
  57. };
  58. PyObject* RedirectWrite(PyObject* self, PyObject* args)
  59. {
  60. std::size_t written(0);
  61. RedirectOutput* selfimpl = reinterpret_cast<RedirectOutput*>(self);
  62. if (selfimpl->write)
  63. {
  64. char* data;
  65. if (!PyArg_ParseTuple(args, "s", &data))
  66. {
  67. return PyLong_FromSize_t(0);
  68. }
  69. selfimpl->write(data);
  70. written = strlen(data);
  71. }
  72. return PyLong_FromSize_t(written);
  73. }
  74. PyObject* RedirectFlush([[maybe_unused]] PyObject* self,[[maybe_unused]] PyObject* args)
  75. {
  76. // no-op
  77. return Py_BuildValue("");
  78. }
  79. PyMethodDef RedirectMethods[] = {
  80. {"write", RedirectWrite, METH_VARARGS, "sys.stdout.write"},
  81. {"flush", RedirectFlush, METH_VARARGS, "sys.stdout.flush"},
  82. {"write", RedirectWrite, METH_VARARGS, "sys.stderr.write"},
  83. {"flush", RedirectFlush, METH_VARARGS, "sys.stderr.flush"},
  84. {0, 0, 0, 0} // sentinel
  85. };
  86. PyTypeObject RedirectOutputType = {
  87. PyVarObject_HEAD_INIT(0, 0) "azlmbr_redirect.RedirectOutputType", // tp_name
  88. sizeof(RedirectOutput), /* tp_basicsize */
  89. 0, /* tp_itemsize */
  90. 0, /* tp_dealloc */
  91. 0, /* tp_print */
  92. 0, /* tp_getattr */
  93. 0, /* tp_setattr */
  94. 0, /* tp_reserved */
  95. 0, /* tp_repr */
  96. 0, /* tp_as_number */
  97. 0, /* tp_as_sequence */
  98. 0, /* tp_as_mapping */
  99. 0, /* tp_hash */
  100. 0, /* tp_call */
  101. 0, /* tp_str */
  102. 0, /* tp_getattro */
  103. 0, /* tp_setattro */
  104. 0, /* tp_as_buffer */
  105. Py_TPFLAGS_DEFAULT, /* tp_flags */
  106. "azlmbr_redirect objects", /* tp_doc */
  107. 0, /* tp_traverse */
  108. 0, /* tp_clear */
  109. 0, /* tp_richcompare */
  110. 0, /* tp_weaklistoffset */
  111. 0, /* tp_iter */
  112. 0, /* tp_iternext */
  113. RedirectMethods, /* tp_methods */
  114. 0, /* tp_members */
  115. 0, /* tp_getset */
  116. 0, /* tp_base */
  117. 0, /* tp_dict */
  118. 0, /* tp_descr_get */
  119. 0, /* tp_descr_set */
  120. 0, /* tp_dictoffset */
  121. 0, /* tp_init */
  122. 0, /* tp_alloc */
  123. 0 /* tp_new */
  124. };
  125. PyModuleDef RedirectOutputModule = {
  126. PyModuleDef_HEAD_INIT, "azlmbr_redirect", 0, -1, 0,
  127. };
  128. // Internal state
  129. PyObject* g_redirect_stdout = nullptr;
  130. PyObject* g_redirect_stdout_saved = nullptr;
  131. PyObject* g_redirect_stderr = nullptr;
  132. PyObject* g_redirect_stderr_saved = nullptr;
  133. PyMODINIT_FUNC PyInit_RedirectOutput(void)
  134. {
  135. g_redirect_stdout = nullptr;
  136. g_redirect_stdout_saved = nullptr;
  137. g_redirect_stderr = nullptr;
  138. g_redirect_stderr_saved = nullptr;
  139. RedirectOutputType.tp_new = PyType_GenericNew;
  140. if (PyType_Ready(&RedirectOutputType) < 0)
  141. {
  142. return 0;
  143. }
  144. PyObject* redirectModule = PyModule_Create(&RedirectOutputModule);
  145. if (redirectModule)
  146. {
  147. Py_INCREF(&RedirectOutputType);
  148. PyModule_AddObject(redirectModule, "Redirect", reinterpret_cast<PyObject*>(&RedirectOutputType));
  149. }
  150. return redirectModule;
  151. }
  152. void SetRedirection(const char* funcname, PyObject*& saved, PyObject*& current, RedirectOutputFunc func)
  153. {
  154. if (PyType_Ready(&RedirectOutputType) < 0)
  155. {
  156. AZ_Warning("python", false, "RedirectOutputType not ready!");
  157. return;
  158. }
  159. if (!current)
  160. {
  161. saved = PySys_GetObject(funcname); // borrowed
  162. current = RedirectOutputType.tp_new(&RedirectOutputType, 0, 0);
  163. }
  164. RedirectOutput* redirectOutput = reinterpret_cast<RedirectOutput*>(current);
  165. redirectOutput->write = func;
  166. PySys_SetObject(funcname, current);
  167. }
  168. void ResetRedirection(const char* funcname, PyObject*& saved, PyObject*& current)
  169. {
  170. if (current)
  171. {
  172. PySys_SetObject(funcname, saved);
  173. }
  174. Py_XDECREF(current);
  175. current = nullptr;
  176. }
  177. PyObject* s_RedirectModule = nullptr;
  178. void Intialize(PyObject* module)
  179. {
  180. s_RedirectModule = module;
  181. SetRedirection("stdout", g_redirect_stdout_saved, g_redirect_stdout, []([[maybe_unused]] const char* msg) {
  182. AZ_TracePrintf("Python", msg);
  183. });
  184. SetRedirection("stderr", g_redirect_stderr_saved, g_redirect_stderr, []([[maybe_unused]] const char* msg) {
  185. AZStd::string lastPythonError = msg;
  186. constexpr const char* pythonErrorPrefix = "ERROR:root:";
  187. constexpr size_t lengthOfErrorPrefix = AZStd::char_traits<char>::length(pythonErrorPrefix);
  188. auto errorPrefix = lastPythonError.find(pythonErrorPrefix);
  189. if (errorPrefix != AZStd::string::npos)
  190. {
  191. lastPythonError.erase(errorPrefix, lengthOfErrorPrefix);
  192. }
  193. O3DE::ProjectManager::PythonBindingsInterface::Get()->AddErrorString(lastPythonError);
  194. AZ_TracePrintf("Python", msg);
  195. });
  196. PySys_WriteStdout("RedirectOutput installed");
  197. }
  198. void Shutdown()
  199. {
  200. ResetRedirection("stdout", g_redirect_stdout_saved, g_redirect_stdout);
  201. ResetRedirection("stderr", g_redirect_stderr_saved, g_redirect_stderr);
  202. Py_XDECREF(s_RedirectModule);
  203. s_RedirectModule = nullptr;
  204. }
  205. } // namespace RedirectOutput
  206. namespace O3DE::ProjectManager
  207. {
  208. PythonBindings::PythonBindings(const AZ::IO::PathView& enginePath)
  209. : m_enginePath(enginePath)
  210. {
  211. m_pythonStarted = StartPython();
  212. }
  213. PythonBindings::~PythonBindings()
  214. {
  215. StopPython();
  216. }
  217. bool PythonBindings::PythonStarted()
  218. {
  219. return m_pythonStarted && Py_IsInitialized();
  220. }
  221. bool PythonBindings::StartPython()
  222. {
  223. if (Py_IsInitialized())
  224. {
  225. AZ_Warning("python", false, "Python is already active");
  226. return m_pythonStarted;
  227. }
  228. m_pythonStarted = false;
  229. // set PYTHON_HOME
  230. AZStd::string pyBasePath = Platform::GetPythonHomePath(PY_PACKAGE, m_enginePath.c_str());
  231. if (!AZ::IO::SystemFile::Exists(pyBasePath.c_str()))
  232. {
  233. AZ_Error("python", false, "Python home path does not exist: %s", pyBasePath.c_str());
  234. return false;
  235. }
  236. AZStd::wstring pyHomePath;
  237. AZStd::to_wstring(pyHomePath, pyBasePath);
  238. Py_SetPythonHome(pyHomePath.c_str());
  239. // display basic Python information
  240. AZ_TracePrintf("python", "Py_GetVersion=%s \n", Py_GetVersion());
  241. AZ_TracePrintf("python", "Py_GetPath=%ls \n", Py_GetPath());
  242. AZ_TracePrintf("python", "Py_GetExecPrefix=%ls \n", Py_GetExecPrefix());
  243. AZ_TracePrintf("python", "Py_GetProgramFullPath=%ls \n", Py_GetProgramFullPath());
  244. PyImport_AppendInittab("azlmbr_redirect", RedirectOutput::PyInit_RedirectOutput);
  245. try
  246. {
  247. // ignore system location for sites site-packages
  248. Py_IsolatedFlag = 1; // -I - Also sets Py_NoUserSiteDirectory. If removed PyNoUserSiteDirectory should be set.
  249. Py_IgnoreEnvironmentFlag = 1; // -E
  250. const bool initializeSignalHandlers = true;
  251. pybind11::initialize_interpreter(initializeSignalHandlers);
  252. RedirectOutput::Intialize(PyImport_ImportModule("azlmbr_redirect"));
  253. // Acquire GIL before calling Python code
  254. AZStd::lock_guard<decltype(m_lock)> lock(m_lock);
  255. pybind11::gil_scoped_acquire acquire;
  256. // sanity import check
  257. if (PyRun_SimpleString("import sys") != 0)
  258. {
  259. AZ_Assert(false, "Import sys failed");
  260. return false;
  261. }
  262. // import required modules
  263. m_cmake = pybind11::module::import("o3de.cmake");
  264. m_register = pybind11::module::import("o3de.register");
  265. m_manifest = pybind11::module::import("o3de.manifest");
  266. m_engineTemplate = pybind11::module::import("o3de.engine_template");
  267. m_engineProperties = pybind11::module::import("o3de.engine_properties");
  268. m_enableGemProject = pybind11::module::import("o3de.enable_gem");
  269. m_disableGemProject = pybind11::module::import("o3de.disable_gem");
  270. m_editProjectProperties = pybind11::module::import("o3de.project_properties");
  271. m_download = pybind11::module::import("o3de.download");
  272. m_repo = pybind11::module::import("o3de.repo");
  273. m_pathlib = pybind11::module::import("pathlib");
  274. m_pythonStarted = !PyErr_Occurred();
  275. return m_pythonStarted;
  276. }
  277. catch ([[maybe_unused]] const std::exception& e)
  278. {
  279. AZ_Assert(false, "Py_Initialize() failed with %s", e.what());
  280. return false;
  281. }
  282. }
  283. bool PythonBindings::StopPython()
  284. {
  285. if (Py_IsInitialized())
  286. {
  287. RedirectOutput::Shutdown();
  288. pybind11::finalize_interpreter();
  289. }
  290. else
  291. {
  292. AZ_Warning("ProjectManagerWindow", false, "Did not finalize since Py_IsInitialized() was false");
  293. }
  294. return !PyErr_Occurred();
  295. }
  296. AZ::Outcome<void, AZStd::string> PythonBindings::ExecuteWithLockErrorHandling(AZStd::function<void()> executionCallback)
  297. {
  298. if (!Py_IsInitialized())
  299. {
  300. return AZ::Failure<AZStd::string>("Python is not initialized");
  301. }
  302. AZStd::lock_guard<decltype(m_lock)> lock(m_lock);
  303. pybind11::gil_scoped_release release;
  304. pybind11::gil_scoped_acquire acquire;
  305. ClearErrorStrings();
  306. try
  307. {
  308. executionCallback();
  309. }
  310. catch ([[maybe_unused]] const std::exception& e)
  311. {
  312. AZ_Warning("PythonBindings", false, "Python exception %s", e.what());
  313. return AZ::Failure<AZStd::string>(e.what());
  314. }
  315. return AZ::Success();
  316. }
  317. bool PythonBindings::ExecuteWithLock(AZStd::function<void()> executionCallback)
  318. {
  319. return ExecuteWithLockErrorHandling(executionCallback).IsSuccess();
  320. }
  321. EngineInfo PythonBindings::EngineInfoFromPath(pybind11::handle enginePath)
  322. {
  323. EngineInfo engineInfo;
  324. try
  325. {
  326. auto engineData = m_manifest.attr("get_engine_json_data")(pybind11::none(), enginePath);
  327. if (pybind11::isinstance<pybind11::dict>(engineData))
  328. {
  329. engineInfo.m_version = Py_To_String_Optional(engineData, "O3DEVersion", "0.0.0.0");
  330. engineInfo.m_name = Py_To_String_Optional(engineData, "engine_name", "O3DE");
  331. engineInfo.m_path = Py_To_String(enginePath);
  332. }
  333. auto o3deData = m_manifest.attr("load_o3de_manifest")();
  334. if (pybind11::isinstance<pybind11::dict>(o3deData))
  335. {
  336. auto defaultGemsFolder = m_manifest.attr("get_o3de_gems_folder")();
  337. engineInfo.m_defaultGemsFolder = Py_To_String_Optional(o3deData, "default_gems_folder", Py_To_String(defaultGemsFolder));
  338. auto defaultProjectsFolder = m_manifest.attr("get_o3de_projects_folder")();
  339. engineInfo.m_defaultProjectsFolder = Py_To_String_Optional(o3deData, "default_projects_folder", Py_To_String(defaultProjectsFolder));
  340. auto defaultRestrictedFolder = m_manifest.attr("get_o3de_restricted_folder")();
  341. engineInfo.m_defaultRestrictedFolder = Py_To_String_Optional(o3deData, "default_restricted_folder", Py_To_String(defaultRestrictedFolder));
  342. auto defaultTemplatesFolder = m_manifest.attr("get_o3de_templates_folder")();
  343. engineInfo.m_defaultTemplatesFolder = Py_To_String_Optional(o3deData, "default_templates_folder", Py_To_String(defaultTemplatesFolder));
  344. auto defaultThirdPartyFolder = m_manifest.attr("get_o3de_third_party_folder")();
  345. engineInfo.m_thirdPartyPath = Py_To_String_Optional(o3deData, "default_third_party_folder", Py_To_String(defaultThirdPartyFolder));
  346. }
  347. // check if engine path is registered
  348. auto allEngines = m_manifest.attr("get_engines")();
  349. if (pybind11::isinstance<pybind11::list>(allEngines))
  350. {
  351. const AZ::IO::FixedMaxPath enginePathFixed(Py_To_String(enginePath));
  352. for (auto engine : allEngines)
  353. {
  354. AZ::IO::FixedMaxPath otherEnginePath(Py_To_String(engine));
  355. if (otherEnginePath.Compare(enginePathFixed) == 0)
  356. {
  357. engineInfo.m_registered = true;
  358. break;
  359. }
  360. }
  361. }
  362. }
  363. catch ([[maybe_unused]] const std::exception& e)
  364. {
  365. AZ_Warning("PythonBindings", false, "Failed to get EngineInfo from %s", Py_To_String(enginePath));
  366. }
  367. return engineInfo;
  368. }
  369. AZ::Outcome<EngineInfo> PythonBindings::GetEngineInfo()
  370. {
  371. EngineInfo engineInfo;
  372. bool result = ExecuteWithLock([&] {
  373. auto enginePath = m_manifest.attr("get_this_engine_path")();
  374. engineInfo = EngineInfoFromPath(enginePath);
  375. });
  376. if (!result || !engineInfo.IsValid())
  377. {
  378. return AZ::Failure();
  379. }
  380. else
  381. {
  382. return AZ::Success(AZStd::move(engineInfo));
  383. }
  384. }
  385. AZ::Outcome<EngineInfo> PythonBindings::GetEngineInfo(const QString& engineName)
  386. {
  387. EngineInfo engineInfo;
  388. bool result = ExecuteWithLock([&] {
  389. auto enginePathResult = m_manifest.attr("get_registered")(QString_To_Py_String(engineName));
  390. // if a valid registered object is not found None is returned
  391. if (!pybind11::isinstance<pybind11::none>(enginePathResult))
  392. {
  393. engineInfo = EngineInfoFromPath(enginePathResult);
  394. }
  395. });
  396. if (!result || !engineInfo.IsValid())
  397. {
  398. return AZ::Failure();
  399. }
  400. else
  401. {
  402. return AZ::Success(AZStd::move(engineInfo));
  403. }
  404. }
  405. IPythonBindings::DetailedOutcome PythonBindings::SetEngineInfo(const EngineInfo& engineInfo, bool force)
  406. {
  407. bool registrationSuccess = false;
  408. bool pythonSuccess = ExecuteWithLock([&] {
  409. EngineInfo currentEngine = EngineInfoFromPath(QString_To_Py_Path(engineInfo.m_path));
  410. // be kind to source control and avoid needlessly updating engine.json
  411. if (currentEngine.IsValid() &&
  412. (currentEngine.m_name.compare(engineInfo.m_name) != 0 || currentEngine.m_version.compare(engineInfo.m_version) != 0))
  413. {
  414. auto enginePropsResult = m_engineProperties.attr("edit_engine_props")(
  415. QString_To_Py_Path(engineInfo.m_path),
  416. pybind11::none(), // existing engine_name
  417. QString_To_Py_String(engineInfo.m_name),
  418. QString_To_Py_String(engineInfo.m_version)
  419. );
  420. if (enginePropsResult.cast<int>() != 0)
  421. {
  422. // do not proceed with registration
  423. return;
  424. }
  425. }
  426. auto result = m_register.attr("register")(
  427. QString_To_Py_Path(engineInfo.m_path),
  428. pybind11::none(), // project_path
  429. pybind11::none(), // gem_path
  430. pybind11::none(), // external_subdir_path
  431. pybind11::none(), // template_path
  432. pybind11::none(), // restricted_path
  433. pybind11::none(), // repo_uri
  434. pybind11::none(), // default_engines_folder
  435. QString_To_Py_Path(engineInfo.m_defaultProjectsFolder),
  436. QString_To_Py_Path(engineInfo.m_defaultGemsFolder),
  437. QString_To_Py_Path(engineInfo.m_defaultTemplatesFolder),
  438. pybind11::none(), // default_restricted_folder
  439. QString_To_Py_Path(engineInfo.m_thirdPartyPath),
  440. pybind11::none(), // external_subdir_engine_path
  441. pybind11::none(), // external_subdir_project_path
  442. false, // remove
  443. force
  444. );
  445. registrationSuccess = result.cast<int>() == 0;
  446. });
  447. if (pythonSuccess && registrationSuccess)
  448. {
  449. return AZ::Success();
  450. }
  451. return AZ::Failure<ErrorPair>(GetErrorPair());
  452. }
  453. AZ::Outcome<GemInfo> PythonBindings::GetGemInfo(const QString& path, const QString& projectPath)
  454. {
  455. GemInfo gemInfo = GemInfoFromPath(QString_To_Py_String(path), QString_To_Py_Path(projectPath));
  456. if (gemInfo.IsValid())
  457. {
  458. return AZ::Success(AZStd::move(gemInfo));
  459. }
  460. else
  461. {
  462. return AZ::Failure();
  463. }
  464. }
  465. AZ::Outcome<QVector<GemInfo>, AZStd::string> PythonBindings::GetEngineGemInfos()
  466. {
  467. QVector<GemInfo> gems;
  468. auto result = ExecuteWithLockErrorHandling([&]
  469. {
  470. for (auto path : m_manifest.attr("get_engine_gems")())
  471. {
  472. gems.push_back(GemInfoFromPath(path, pybind11::none()));
  473. }
  474. });
  475. if (!result.IsSuccess())
  476. {
  477. return AZ::Failure<AZStd::string>(result.GetError().c_str());
  478. }
  479. std::sort(gems.begin(), gems.end());
  480. return AZ::Success(AZStd::move(gems));
  481. }
  482. AZ::Outcome<QVector<GemInfo>, AZStd::string> PythonBindings::GetAllGemInfos(const QString& projectPath)
  483. {
  484. QVector<GemInfo> gems;
  485. auto result = ExecuteWithLockErrorHandling([&]
  486. {
  487. auto pyProjectPath = QString_To_Py_Path(projectPath);
  488. for (auto path : m_manifest.attr("get_all_gems")(pyProjectPath))
  489. {
  490. GemInfo gemInfo = GemInfoFromPath(path, pyProjectPath);
  491. // Mark as downloaded because this gem was registered with an existing directory
  492. gemInfo.m_downloadStatus = GemInfo::DownloadStatus::Downloaded;
  493. gems.push_back(AZStd::move(gemInfo));
  494. }
  495. });
  496. if (!result.IsSuccess())
  497. {
  498. return AZ::Failure<AZStd::string>(result.GetError().c_str());
  499. }
  500. std::sort(gems.begin(), gems.end());
  501. return AZ::Success(AZStd::move(gems));
  502. }
  503. AZ::Outcome<QVector<AZStd::string>, AZStd::string> PythonBindings::GetEnabledGemNames(const QString& projectPath)
  504. {
  505. // Retrieve the path to the cmake file that lists the enabled gems.
  506. pybind11::str enabledGemsFilename;
  507. auto result = ExecuteWithLockErrorHandling([&]
  508. {
  509. enabledGemsFilename = m_cmake.attr("get_enabled_gem_cmake_file")(
  510. pybind11::none(), // project_name
  511. QString_To_Py_Path(projectPath)); // project_path
  512. });
  513. if (!result.IsSuccess())
  514. {
  515. return AZ::Failure<AZStd::string>(result.GetError().c_str());
  516. }
  517. // Retrieve the actual list of names from the cmake file.
  518. QVector<AZStd::string> gemNames;
  519. result = ExecuteWithLockErrorHandling([&]
  520. {
  521. const auto pyGemNames = m_cmake.attr("get_enabled_gems")(enabledGemsFilename);
  522. for (auto gemName : pyGemNames)
  523. {
  524. gemNames.push_back(Py_To_String(gemName));
  525. }
  526. });
  527. if (!result.IsSuccess())
  528. {
  529. return AZ::Failure<AZStd::string>(result.GetError().c_str());
  530. }
  531. return AZ::Success(AZStd::move(gemNames));
  532. }
  533. AZ::Outcome<void, AZStd::string> PythonBindings::GemRegistration(const QString& gemPath, const QString& projectPath, bool remove)
  534. {
  535. bool registrationResult = false;
  536. auto result = ExecuteWithLockErrorHandling(
  537. [&]
  538. {
  539. auto externalProjectPath = projectPath.isEmpty() ? pybind11::none() : QString_To_Py_Path(projectPath);
  540. auto pythonRegistrationResult = m_register.attr("register")(
  541. pybind11::none(), // engine_path
  542. pybind11::none(), // project_path
  543. QString_To_Py_Path(gemPath), // gem folder
  544. pybind11::none(), // external subdirectory
  545. pybind11::none(), // template_path
  546. pybind11::none(), // restricted folder
  547. pybind11::none(), // repo uri
  548. pybind11::none(), // default_engines_folder
  549. pybind11::none(), // default_projects_folder
  550. pybind11::none(), // default_gems_folder
  551. pybind11::none(), // default_templates_folder
  552. pybind11::none(), // default_restricted_folder
  553. pybind11::none(), // default_third_party_folder
  554. pybind11::none(), // external_subdir_engine_path
  555. externalProjectPath, // external_subdir_project_path
  556. remove // remove
  557. );
  558. // Returns an exit code so boolify it then invert result
  559. registrationResult = !pythonRegistrationResult.cast<bool>();
  560. });
  561. if (!result.IsSuccess())
  562. {
  563. return AZ::Failure<AZStd::string>(result.GetError().c_str());
  564. }
  565. else if (!registrationResult)
  566. {
  567. return AZ::Failure<AZStd::string>(AZStd::string::format(
  568. "Failed to %s gem path %s", remove ? "unregister" : "register", gemPath.toUtf8().constData()));
  569. }
  570. return AZ::Success();
  571. }
  572. AZ::Outcome<void, AZStd::string> PythonBindings::RegisterGem(const QString& gemPath, const QString& projectPath)
  573. {
  574. return GemRegistration(gemPath, projectPath);
  575. }
  576. AZ::Outcome<void, AZStd::string> PythonBindings::UnregisterGem(const QString& gemPath, const QString& projectPath)
  577. {
  578. return GemRegistration(gemPath, projectPath, /*remove*/true);
  579. }
  580. bool PythonBindings::AddProject(const QString& path)
  581. {
  582. bool registrationResult = false;
  583. bool result = ExecuteWithLock(
  584. [&]
  585. {
  586. auto projectPath = QString_To_Py_Path(path);
  587. auto pythonRegistrationResult = m_register.attr("register")(pybind11::none(), projectPath);
  588. // Returns an exit code so boolify it then invert result
  589. registrationResult = !pythonRegistrationResult.cast<bool>();
  590. });
  591. return result && registrationResult;
  592. }
  593. bool PythonBindings::RemoveProject(const QString& path)
  594. {
  595. bool registrationResult = false;
  596. bool result = ExecuteWithLock(
  597. [&]
  598. {
  599. auto pythonRegistrationResult = m_register.attr("register")(
  600. pybind11::none(), // engine_path
  601. QString_To_Py_Path(path), // project_path
  602. pybind11::none(), // gem_path
  603. pybind11::none(), // external_subdir_path
  604. pybind11::none(), // template_path
  605. pybind11::none(), // restricted_path
  606. pybind11::none(), // repo_uri
  607. pybind11::none(), // default_engines_folder
  608. pybind11::none(), // default_projects_folder
  609. pybind11::none(), // default_gems_folder
  610. pybind11::none(), // default_templates_folder
  611. pybind11::none(), // default_restricted_folder
  612. pybind11::none(), // default_third_party_folder
  613. pybind11::none(), // external_subdir_engine_path
  614. pybind11::none(), // external_subdir_project_path
  615. true, // remove
  616. false // force
  617. );
  618. // Returns an exit code so boolify it then invert result
  619. registrationResult = !pythonRegistrationResult.cast<bool>();
  620. });
  621. return result && registrationResult;
  622. }
  623. AZ::Outcome<ProjectInfo> PythonBindings::CreateProject(const QString& projectTemplatePath, const ProjectInfo& projectInfo)
  624. {
  625. ProjectInfo createdProjectInfo;
  626. bool result = ExecuteWithLock([&] {
  627. auto projectPath = QString_To_Py_Path(projectInfo.m_path);
  628. auto createProjectResult = m_engineTemplate.attr("create_project")(
  629. projectPath,
  630. QString_To_Py_String(projectInfo.m_projectName), // project_path
  631. QString_To_Py_Path(projectTemplatePath) // template_path
  632. );
  633. if (createProjectResult.cast<int>() == 0)
  634. {
  635. createdProjectInfo = ProjectInfoFromPath(projectPath);
  636. }
  637. });
  638. if (!result || !createdProjectInfo.IsValid())
  639. {
  640. return AZ::Failure();
  641. }
  642. else
  643. {
  644. return AZ::Success(AZStd::move(createdProjectInfo));
  645. }
  646. }
  647. AZ::Outcome<ProjectInfo> PythonBindings::GetProject(const QString& path)
  648. {
  649. ProjectInfo projectInfo = ProjectInfoFromPath(QString_To_Py_Path(path));
  650. if (projectInfo.IsValid())
  651. {
  652. return AZ::Success(AZStd::move(projectInfo));
  653. }
  654. else
  655. {
  656. return AZ::Failure();
  657. }
  658. }
  659. GemInfo PythonBindings::GemInfoFromPath(pybind11::handle path, pybind11::handle pyProjectPath)
  660. {
  661. GemInfo gemInfo;
  662. gemInfo.m_path = Py_To_String(path);
  663. gemInfo.m_directoryLink = gemInfo.m_path;
  664. auto data = m_manifest.attr("get_gem_json_data")(pybind11::none(), path, pyProjectPath);
  665. if (pybind11::isinstance<pybind11::dict>(data))
  666. {
  667. try
  668. {
  669. // required
  670. gemInfo.m_name = Py_To_String(data["gem_name"]);
  671. // optional
  672. gemInfo.m_displayName = Py_To_String_Optional(data, "display_name", gemInfo.m_name);
  673. gemInfo.m_summary = Py_To_String_Optional(data, "summary", "");
  674. gemInfo.m_version = Py_To_String_Optional(data, "version", gemInfo.m_version);
  675. gemInfo.m_lastUpdatedDate = Py_To_String_Optional(data, "last_updated", gemInfo.m_lastUpdatedDate);
  676. gemInfo.m_binarySizeInKB = Py_To_Int_Optional(data, "binary_size", gemInfo.m_binarySizeInKB);
  677. gemInfo.m_requirement = Py_To_String_Optional(data, "requirements", "");
  678. gemInfo.m_creator = Py_To_String_Optional(data, "origin", "");
  679. gemInfo.m_documentationLink = Py_To_String_Optional(data, "documentation_url", "");
  680. gemInfo.m_licenseText = Py_To_String_Optional(data, "license", "Unspecified License");
  681. gemInfo.m_licenseLink = Py_To_String_Optional(data, "license_url", "");
  682. gemInfo.m_repoUri = Py_To_String_Optional(data, "repo_uri", "");
  683. if (gemInfo.m_creator.contains("Open 3D Engine"))
  684. {
  685. gemInfo.m_gemOrigin = GemInfo::GemOrigin::Open3DEngine;
  686. }
  687. else if (gemInfo.m_creator.contains("Amazon Web Services"))
  688. {
  689. gemInfo.m_gemOrigin = GemInfo::GemOrigin::Local;
  690. }
  691. else if (data.contains("origin"))
  692. {
  693. gemInfo.m_gemOrigin = GemInfo::GemOrigin::Remote;
  694. }
  695. // If no origin was provided this cannot be remote and would be specified if O3DE so it should be local
  696. else
  697. {
  698. gemInfo.m_gemOrigin = GemInfo::GemOrigin::Local;
  699. }
  700. // As long Base Open3DEngine gems are installed before first startup non-remote gems will be downloaded
  701. if (gemInfo.m_gemOrigin != GemInfo::GemOrigin::Remote)
  702. {
  703. gemInfo.m_downloadStatus = GemInfo::DownloadStatus::Downloaded;
  704. }
  705. if (data.contains("user_tags"))
  706. {
  707. for (auto tag : data["user_tags"])
  708. {
  709. gemInfo.m_features.push_back(Py_To_String(tag));
  710. }
  711. }
  712. if (data.contains("dependencies"))
  713. {
  714. for (auto dependency : data["dependencies"])
  715. {
  716. gemInfo.m_dependencies.push_back(Py_To_String(dependency));
  717. }
  718. }
  719. QString gemType = Py_To_String_Optional(data, "type", "");
  720. if (gemType == "Asset")
  721. {
  722. gemInfo.m_types |= GemInfo::Type::Asset;
  723. }
  724. if (gemType == "Code")
  725. {
  726. gemInfo.m_types |= GemInfo::Type::Code;
  727. }
  728. if (gemType == "Tool")
  729. {
  730. gemInfo.m_types |= GemInfo::Type::Tool;
  731. }
  732. }
  733. catch ([[maybe_unused]] const std::exception& e)
  734. {
  735. AZ_Warning("PythonBindings", false, "Failed to get GemInfo for gem %s", Py_To_String(path));
  736. }
  737. }
  738. return gemInfo;
  739. }
  740. ProjectInfo PythonBindings::ProjectInfoFromPath(pybind11::handle path)
  741. {
  742. ProjectInfo projectInfo;
  743. projectInfo.m_path = Py_To_String(path);
  744. projectInfo.m_needsBuild = false;
  745. auto projectData = m_manifest.attr("get_project_json_data")(pybind11::none(), path);
  746. if (pybind11::isinstance<pybind11::dict>(projectData))
  747. {
  748. try
  749. {
  750. projectInfo.m_projectName = Py_To_String(projectData["project_name"]);
  751. projectInfo.m_displayName = Py_To_String_Optional(projectData, "display_name", projectInfo.m_projectName);
  752. projectInfo.m_id = Py_To_String_Optional(projectData, "project_id", projectInfo.m_id);
  753. projectInfo.m_origin = Py_To_String_Optional(projectData, "origin", projectInfo.m_origin);
  754. projectInfo.m_summary = Py_To_String_Optional(projectData, "summary", projectInfo.m_summary);
  755. projectInfo.m_iconPath = Py_To_String_Optional(projectData, "icon", ProjectPreviewImagePath);
  756. if (projectData.contains("user_tags"))
  757. {
  758. for (auto tag : projectData["user_tags"])
  759. {
  760. projectInfo.m_userTags.append(Py_To_String(tag));
  761. }
  762. }
  763. }
  764. catch ([[maybe_unused]] const std::exception& e)
  765. {
  766. AZ_Warning("PythonBindings", false, "Failed to get ProjectInfo for project %s", Py_To_String(path));
  767. }
  768. }
  769. return projectInfo;
  770. }
  771. AZ::Outcome<QVector<ProjectInfo>> PythonBindings::GetProjects()
  772. {
  773. QVector<ProjectInfo> projects;
  774. bool result = ExecuteWithLock([&] {
  775. // external projects
  776. for (auto path : m_manifest.attr("get_projects")())
  777. {
  778. projects.push_back(ProjectInfoFromPath(path));
  779. }
  780. // projects from the engine
  781. for (auto path : m_manifest.attr("get_engine_projects")())
  782. {
  783. projects.push_back(ProjectInfoFromPath(path));
  784. }
  785. });
  786. if (!result)
  787. {
  788. return AZ::Failure();
  789. }
  790. else
  791. {
  792. return AZ::Success(AZStd::move(projects));
  793. }
  794. }
  795. AZ::Outcome<void, AZStd::string> PythonBindings::AddGemToProject(const QString& gemPath, const QString& projectPath)
  796. {
  797. return ExecuteWithLockErrorHandling([&]
  798. {
  799. m_enableGemProject.attr("enable_gem_in_project")(
  800. pybind11::none(), // gem name not needed as path is provided
  801. QString_To_Py_Path(gemPath),
  802. pybind11::none(), // project name not needed as path is provided
  803. QString_To_Py_Path(projectPath)
  804. );
  805. });
  806. }
  807. AZ::Outcome<void, AZStd::string> PythonBindings::RemoveGemFromProject(const QString& gemPath, const QString& projectPath)
  808. {
  809. return ExecuteWithLockErrorHandling([&]
  810. {
  811. m_disableGemProject.attr("disable_gem_in_project")(
  812. pybind11::none(), // gem name not needed as path is provided
  813. QString_To_Py_Path(gemPath),
  814. pybind11::none(), // project name not needed as path is provided
  815. QString_To_Py_Path(projectPath)
  816. );
  817. });
  818. }
  819. bool PythonBindings::RemoveInvalidProjects()
  820. {
  821. bool removalResult = false;
  822. bool result = ExecuteWithLock(
  823. [&]
  824. {
  825. auto pythonRemovalResult = m_register.attr("remove_invalid_o3de_projects")();
  826. // Returns an exit code so boolify it then invert result
  827. removalResult = !pythonRemovalResult.cast<bool>();
  828. });
  829. return result && removalResult;
  830. }
  831. AZ::Outcome<void, AZStd::string> PythonBindings::UpdateProject(const ProjectInfo& projectInfo)
  832. {
  833. bool updateProjectSucceeded = false;
  834. auto result = ExecuteWithLockErrorHandling([&]
  835. {
  836. std::list<std::string> newTags;
  837. for (const auto& i : projectInfo.m_userTags)
  838. {
  839. newTags.push_back(i.toStdString());
  840. }
  841. auto editResult = m_editProjectProperties.attr("edit_project_props")(
  842. QString_To_Py_Path(projectInfo.m_path),
  843. pybind11::none(), // proj_name not used
  844. QString_To_Py_String(projectInfo.m_projectName),
  845. QString_To_Py_String(projectInfo.m_id),
  846. QString_To_Py_String(projectInfo.m_origin),
  847. QString_To_Py_String(projectInfo.m_displayName),
  848. QString_To_Py_String(projectInfo.m_summary),
  849. QString_To_Py_String(projectInfo.m_iconPath), // new_icon
  850. pybind11::none(), // add_tags not used
  851. pybind11::none(), // remove_tags not used
  852. pybind11::list(pybind11::cast(newTags)));
  853. updateProjectSucceeded = (editResult.cast<int>() == 0);
  854. });
  855. if (!result.IsSuccess())
  856. {
  857. return result;
  858. }
  859. else if (!updateProjectSucceeded)
  860. {
  861. return AZ::Failure<AZStd::string>("Failed to update project.");
  862. }
  863. return AZ::Success();
  864. }
  865. ProjectTemplateInfo PythonBindings::ProjectTemplateInfoFromPath(pybind11::handle path, pybind11::handle pyProjectPath)
  866. {
  867. ProjectTemplateInfo templateInfo;
  868. templateInfo.m_path = Py_To_String(path);
  869. auto data = m_manifest.attr("get_template_json_data")(pybind11::none(), path, pyProjectPath);
  870. if (pybind11::isinstance<pybind11::dict>(data))
  871. {
  872. try
  873. {
  874. // required
  875. templateInfo.m_displayName = Py_To_String(data["display_name"]);
  876. templateInfo.m_name = Py_To_String(data["template_name"]);
  877. templateInfo.m_summary = Py_To_String(data["summary"]);
  878. // optional
  879. if (data.contains("canonical_tags"))
  880. {
  881. for (auto tag : data["canonical_tags"])
  882. {
  883. templateInfo.m_canonicalTags.push_back(Py_To_String(tag));
  884. }
  885. }
  886. if (data.contains("user_tags"))
  887. {
  888. for (auto tag : data["user_tags"])
  889. {
  890. templateInfo.m_canonicalTags.push_back(Py_To_String(tag));
  891. }
  892. }
  893. QString templateProjectPath = QDir(templateInfo.m_path).filePath("Template");
  894. auto enabledGemNames = GetEnabledGemNames(templateProjectPath);
  895. if (enabledGemNames)
  896. {
  897. for (auto gem : enabledGemNames.GetValue())
  898. {
  899. // Exclude the template ${Name} placeholder for the list of included gems
  900. // That Gem gets created with the project
  901. if (!gem.contains("${Name}"))
  902. {
  903. templateInfo.m_includedGems.push_back(Py_To_String(gem.c_str()));
  904. }
  905. }
  906. }
  907. }
  908. catch ([[maybe_unused]] const std::exception& e)
  909. {
  910. AZ_Warning("PythonBindings", false, "Failed to get ProjectTemplateInfo for %s", Py_To_String(path));
  911. }
  912. }
  913. return templateInfo;
  914. }
  915. AZ::Outcome<QVector<ProjectTemplateInfo>> PythonBindings::GetProjectTemplates(const QString& projectPath)
  916. {
  917. QVector<ProjectTemplateInfo> templates;
  918. bool result = ExecuteWithLock([&] {
  919. for (auto path : m_manifest.attr("get_templates_for_project_creation")())
  920. {
  921. templates.push_back(ProjectTemplateInfoFromPath(path, QString_To_Py_Path(projectPath)));
  922. }
  923. });
  924. if (!result)
  925. {
  926. return AZ::Failure();
  927. }
  928. else
  929. {
  930. return AZ::Success(AZStd::move(templates));
  931. }
  932. }
  933. AZ::Outcome<void, AZStd::string> PythonBindings::RefreshGemRepo(const QString& repoUri)
  934. {
  935. bool refreshResult = false;
  936. AZ::Outcome<void, AZStd::string> result = ExecuteWithLockErrorHandling(
  937. [&]
  938. {
  939. auto pyUri = QString_To_Py_String(repoUri);
  940. auto pythonRefreshResult = m_repo.attr("refresh_repo")(pyUri);
  941. // Returns an exit code so boolify it then invert result
  942. refreshResult = !pythonRefreshResult.cast<bool>();
  943. });
  944. if (!result.IsSuccess())
  945. {
  946. return result;
  947. }
  948. else if (!refreshResult)
  949. {
  950. return AZ::Failure<AZStd::string>("Failed to refresh repo.");
  951. }
  952. return AZ::Success();
  953. }
  954. bool PythonBindings::RefreshAllGemRepos()
  955. {
  956. bool refreshResult = false;
  957. bool result = ExecuteWithLock(
  958. [&]
  959. {
  960. auto pythonRefreshResult = m_repo.attr("refresh_repos")();
  961. // Returns an exit code so boolify it then invert result
  962. refreshResult = !pythonRefreshResult.cast<bool>();
  963. });
  964. return result && refreshResult;
  965. }
  966. IPythonBindings::DetailedOutcome PythonBindings::AddGemRepo(const QString& repoUri)
  967. {
  968. bool registrationResult = false;
  969. bool result = ExecuteWithLock(
  970. [&]
  971. {
  972. auto pyUri = QString_To_Py_String(repoUri);
  973. auto pythonRegistrationResult = m_register.attr("register")(
  974. pybind11::none(), pybind11::none(), pybind11::none(), pybind11::none(), pybind11::none(), pybind11::none(), pyUri);
  975. // Returns an exit code so boolify it then invert result
  976. registrationResult = !pythonRegistrationResult.cast<bool>();
  977. });
  978. if (!result || !registrationResult)
  979. {
  980. return AZ::Failure<IPythonBindings::ErrorPair>(GetErrorPair());
  981. }
  982. return AZ::Success();
  983. }
  984. bool PythonBindings::RemoveGemRepo(const QString& repoUri)
  985. {
  986. bool registrationResult = false;
  987. bool result = ExecuteWithLock(
  988. [&]
  989. {
  990. auto pythonRegistrationResult = m_register.attr("register")(
  991. pybind11::none(), // engine_path
  992. pybind11::none(), // project_path
  993. pybind11::none(), // gem_path
  994. pybind11::none(), // external_subdir_path
  995. pybind11::none(), // template_path
  996. pybind11::none(), // restricted_path
  997. QString_To_Py_String(repoUri), // repo_uri
  998. pybind11::none(), // default_engines_folder
  999. pybind11::none(), // default_projects_folder
  1000. pybind11::none(), // default_gems_folder
  1001. pybind11::none(), // default_templates_folder
  1002. pybind11::none(), // default_restricted_folder
  1003. pybind11::none(), // default_third_party_folder
  1004. pybind11::none(), // external_subdir_engine_path
  1005. pybind11::none(), // external_subdir_project_path
  1006. true, // remove
  1007. false // force
  1008. );
  1009. // Returns an exit code so boolify it then invert result
  1010. registrationResult = !pythonRegistrationResult.cast<bool>();
  1011. });
  1012. return result && registrationResult;
  1013. }
  1014. GemRepoInfo PythonBindings::GetGemRepoInfo(pybind11::handle repoUri)
  1015. {
  1016. GemRepoInfo gemRepoInfo;
  1017. gemRepoInfo.m_repoUri = Py_To_String(repoUri);
  1018. auto data = m_manifest.attr("get_repo_json_data")(repoUri);
  1019. if (pybind11::isinstance<pybind11::dict>(data))
  1020. {
  1021. try
  1022. {
  1023. // required
  1024. gemRepoInfo.m_repoUri = Py_To_String(data["repo_uri"]);
  1025. gemRepoInfo.m_name = Py_To_String(data["repo_name"]);
  1026. gemRepoInfo.m_creator = Py_To_String(data["origin"]);
  1027. // optional
  1028. gemRepoInfo.m_summary = Py_To_String_Optional(data, "summary", "No summary provided.");
  1029. gemRepoInfo.m_additionalInfo = Py_To_String_Optional(data, "additional_info", "");
  1030. auto repoPath = m_manifest.attr("get_repo_path")(repoUri);
  1031. gemRepoInfo.m_path = gemRepoInfo.m_directoryLink = Py_To_String(repoPath);
  1032. QString lastUpdated = Py_To_String_Optional(data, "last_updated", "");
  1033. gemRepoInfo.m_lastUpdated = QDateTime::fromString(lastUpdated, RepoTimeFormat);
  1034. if (data.contains("enabled"))
  1035. {
  1036. gemRepoInfo.m_isEnabled = data["enabled"].cast<bool>();
  1037. }
  1038. else
  1039. {
  1040. gemRepoInfo.m_isEnabled = false;
  1041. }
  1042. if (data.contains("gems"))
  1043. {
  1044. for (auto gemPath : data["gems"])
  1045. {
  1046. gemRepoInfo.m_includedGemUris.push_back(Py_To_String(gemPath));
  1047. }
  1048. }
  1049. }
  1050. catch ([[maybe_unused]] const std::exception& e)
  1051. {
  1052. AZ_Warning("PythonBindings", false, "Failed to get GemRepoInfo for repo %s", Py_To_String(repoUri));
  1053. }
  1054. }
  1055. return gemRepoInfo;
  1056. }
  1057. AZ::Outcome<QVector<GemRepoInfo>, AZStd::string> PythonBindings::GetAllGemRepoInfos()
  1058. {
  1059. QVector<GemRepoInfo> gemRepos;
  1060. auto result = ExecuteWithLockErrorHandling(
  1061. [&]
  1062. {
  1063. for (auto repoUri : m_manifest.attr("get_manifest_repos")())
  1064. {
  1065. gemRepos.push_back(GetGemRepoInfo(repoUri));
  1066. }
  1067. });
  1068. if (!result.IsSuccess())
  1069. {
  1070. return AZ::Failure<AZStd::string>(result.GetError().c_str());
  1071. }
  1072. std::sort(gemRepos.begin(), gemRepos.end());
  1073. return AZ::Success(AZStd::move(gemRepos));
  1074. }
  1075. AZ::Outcome<QVector<GemInfo>, AZStd::string> PythonBindings::GetGemInfosForRepo(const QString& repoUri)
  1076. {
  1077. QVector<GemInfo> gemInfos;
  1078. AZ::Outcome<void, AZStd::string> result = ExecuteWithLockErrorHandling(
  1079. [&]
  1080. {
  1081. auto pyUri = QString_To_Py_String(repoUri);
  1082. auto gemPaths = m_repo.attr("get_gem_json_paths_from_cached_repo")(pyUri);
  1083. if (pybind11::isinstance<pybind11::set>(gemPaths))
  1084. {
  1085. for (auto path : gemPaths)
  1086. {
  1087. GemInfo gemInfo = GemInfoFromPath(path, pybind11::none());
  1088. gemInfo.m_downloadStatus = GemInfo::DownloadStatus::NotDownloaded;
  1089. gemInfos.push_back(gemInfo);
  1090. }
  1091. }
  1092. });
  1093. if (!result.IsSuccess())
  1094. {
  1095. return AZ::Failure(result.GetError());
  1096. }
  1097. return AZ::Success(AZStd::move(gemInfos));
  1098. }
  1099. AZ::Outcome<QVector<GemInfo>, AZStd::string> PythonBindings::GetGemInfosForAllRepos()
  1100. {
  1101. QVector<GemInfo> gemInfos;
  1102. AZ::Outcome<void, AZStd::string> result = ExecuteWithLockErrorHandling(
  1103. [&]
  1104. {
  1105. auto gemPaths = m_repo.attr("get_gem_json_paths_from_all_cached_repos")();
  1106. if (pybind11::isinstance<pybind11::set>(gemPaths))
  1107. {
  1108. for (auto path : gemPaths)
  1109. {
  1110. GemInfo gemInfo = GemInfoFromPath(path, pybind11::none());
  1111. gemInfo.m_downloadStatus = GemInfo::DownloadStatus::NotDownloaded;
  1112. gemInfos.push_back(gemInfo);
  1113. }
  1114. }
  1115. });
  1116. if (!result.IsSuccess())
  1117. {
  1118. return AZ::Failure(result.GetError());
  1119. }
  1120. return AZ::Success(AZStd::move(gemInfos));
  1121. }
  1122. IPythonBindings::DetailedOutcome PythonBindings::DownloadGem(
  1123. const QString& gemName, std::function<void(int, int)> gemProgressCallback, bool force)
  1124. {
  1125. // This process is currently limited to download a single gem at a time.
  1126. bool downloadSucceeded = false;
  1127. m_requestCancelDownload = false;
  1128. auto result = ExecuteWithLockErrorHandling(
  1129. [&]
  1130. {
  1131. auto downloadResult = m_download.attr("download_gem")(
  1132. QString_To_Py_String(gemName), // gem name
  1133. pybind11::none(), // destination path
  1134. false, // skip auto register
  1135. force, // force overwrite
  1136. pybind11::cpp_function(
  1137. [this, gemProgressCallback](int bytesDownloaded, int totalBytes)
  1138. {
  1139. gemProgressCallback(bytesDownloaded, totalBytes);
  1140. return m_requestCancelDownload;
  1141. }) // Callback for download progress and cancelling
  1142. );
  1143. downloadSucceeded = (downloadResult.cast<int>() == 0);
  1144. });
  1145. if (!result.IsSuccess())
  1146. {
  1147. IPythonBindings::ErrorPair pythonRunError(result.GetError(), result.GetError());
  1148. return AZ::Failure<IPythonBindings::ErrorPair>(AZStd::move(pythonRunError));
  1149. }
  1150. else if (!downloadSucceeded)
  1151. {
  1152. return AZ::Failure<IPythonBindings::ErrorPair>(GetErrorPair());
  1153. }
  1154. return AZ::Success();
  1155. }
  1156. void PythonBindings::CancelDownload()
  1157. {
  1158. m_requestCancelDownload = true;
  1159. }
  1160. bool PythonBindings::IsGemUpdateAvaliable(const QString& gemName, const QString& lastUpdated)
  1161. {
  1162. bool updateAvaliableResult = false;
  1163. bool result = ExecuteWithLock(
  1164. [&]
  1165. {
  1166. auto pyGemName = QString_To_Py_String(gemName);
  1167. auto pyLastUpdated = QString_To_Py_String(lastUpdated);
  1168. auto pythonUpdateAvaliableResult = m_download.attr("is_o3de_gem_update_available")(pyGemName, pyLastUpdated);
  1169. updateAvaliableResult = pythonUpdateAvaliableResult.cast<bool>();
  1170. });
  1171. return result && updateAvaliableResult;
  1172. }
  1173. IPythonBindings::ErrorPair PythonBindings::GetErrorPair()
  1174. {
  1175. AZStd::string detailedString = m_pythonErrorStrings.size() == 1
  1176. ? ""
  1177. : AZStd::accumulate(m_pythonErrorStrings.begin(), m_pythonErrorStrings.end(), AZStd::string(""));
  1178. return IPythonBindings::ErrorPair(m_pythonErrorStrings.front(), detailedString);
  1179. }
  1180. void PythonBindings::AddErrorString(AZStd::string errorString)
  1181. {
  1182. m_pythonErrorStrings.push_back(errorString);
  1183. }
  1184. void PythonBindings::ClearErrorStrings()
  1185. {
  1186. m_pythonErrorStrings.clear();
  1187. }
  1188. }