package_manager.js 6.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161
  1. const { writeFileSync, mkdirSync, readFileSync } = require("fs");
  2. const { exec, execSync } = require("child_process");
  3. const { dashCard } = require('../components/dashCard');
  4. const yaml = require('js-yaml');
  5. module.exports.install = async function (data) {
  6. let { service_name, name, image, command_check, command, net_mode, restart_policy } = data;
  7. let { port0, port1, port2, port3, port4, port5 } = data;
  8. let { volume0, volume1, volume2, volume3, volume4, volume5 } = data;
  9. let { env0, env1, env2, env3, env4, env5, env6, env7, env8, env9, env10, env11 } = data;
  10. let { label0, label1, label2, label3, label4, label5, label6, label7, label8, label9, label10, label11 } = data;
  11. if (image.startsWith('https://')){
  12. mkdirSync(`./appdata/${name}`, { recursive: true });
  13. execSync(`curl -o ./appdata/${name}/${name}_stack.yml -L ${image}`);
  14. console.log(`Downloaded stackfile: ${image}`);
  15. let stackfile = yaml.load(readFileSync(`./appdata/${name}/${name}_stack.yml`, 'utf8'));
  16. let services = Object.keys(stackfile.services);
  17. for ( let i = 0; i < services.length; i++ ) {
  18. try {
  19. console.log(stackfile.services[Object.keys(stackfile.services)[i]].environment);
  20. } catch { console.log('no env') }
  21. }
  22. } else {
  23. let compose_file = `version: '3'`;
  24. compose_file += `\nservices:`
  25. compose_file += `\n ${service_name}:`
  26. compose_file += `\n container_name: ${name}`;
  27. compose_file += `\n image: ${image}`;
  28. // Command
  29. if (command_check == 'on') {
  30. compose_file += `\n command: ${command}`
  31. }
  32. // Network mode
  33. if (net_mode == 'host') {
  34. compose_file += `\n network_mode: 'host'`
  35. }
  36. else if (net_mode != 'host' && net_mode != 'docker') {
  37. compose_file += `\n network_mode: '${net_mode}'`
  38. }
  39. // Restart policy
  40. if (restart_policy != '') {
  41. compose_file += `\n restart: ${restart_policy}`
  42. }
  43. // Ports
  44. if ((port0 == 'on' || port1 == 'on' || port2 == 'on' || port3 == 'on' || port4 == 'on' || port5 == 'on') && (net_mode != 'host')) {
  45. compose_file += `\n ports:`
  46. for (let i = 0; i < 6; i++) {
  47. if (data[`port${i}`] == 'on') {
  48. compose_file += `\n - ${data[`port_${i}_external`]}:${data[`port_${i}_internal`]}/${data[`port_${i}_protocol`]}`
  49. }
  50. }
  51. }
  52. // Volumes
  53. if (volume0 == 'on' || volume1 == 'on' || volume2 == 'on' || volume3 == 'on' || volume4 == 'on' || volume5 == 'on') {
  54. compose_file += `\n volumes:`
  55. for (let i = 0; i < 6; i++) {
  56. if (data[`volume${i}`] == 'on') {
  57. compose_file += `\n - ${data[`volume_${i}_bind`]}:${data[`volume_${i}_container`]}:${data[`volume_${i}_readwrite`]}`
  58. }
  59. }
  60. }
  61. // Environment variables
  62. if (env0 == 'on' || env1 == 'on' || env2 == 'on' || env3 == 'on' || env4 == 'on' || env5 == 'on' || env6 == 'on' || env7 == 'on' || env8 == 'on' || env9 == 'on' || env10 == 'on' || env11 == 'on') {
  63. compose_file += `\n environment:`
  64. }
  65. for (let i = 0; i < 12; i++) {
  66. if (data[`env${i}`] == 'on') {
  67. compose_file += `\n - ${data[`env_${i}_name`]}=${data[`env_${i}_default`]}`
  68. }
  69. }
  70. // Add labels
  71. if (label0 == 'on' || label1 == 'on' || label2 == 'on' || label3 == 'on' || label4 == 'on' || label5 == 'on' || label6 == 'on' || label7 == 'on' || label8 == 'on' || label9 == 'on' || label10 == 'on' || label11 == 'on') {
  72. compose_file += `\n labels:`
  73. }
  74. for (let i = 0; i < 12; i++) {
  75. if (data[`label${i}`] == 'on') {
  76. compose_file += `\n - ${data[`label_${i}_name`]}=${data[`label_${i}_value`]}`
  77. }
  78. }
  79. // Add privileged mode
  80. if (data.privileged == 'on') {
  81. compose_file += `\n privileged: true`
  82. }
  83. // Add hardware acceleration to the docker-compose file if one of the environment variables has the label DRINODE
  84. if (env0 == 'on' || env1 == 'on' || env2 == 'on' || env3 == 'on' || env4 == 'on' || env5 == 'on' || env6 == 'on' || env7 == 'on' || env8 == 'on' || env9 == 'on' || env10 == 'on' || env11 == 'on') {
  85. for (let i = 0; i < 12; i++) {
  86. if (data[`env${i}`] == 'on') {
  87. if (data[`env_${i}_name`] == 'DRINODE') {
  88. compose_file += `\n deploy:`
  89. compose_file += `\n resources:`
  90. compose_file += `\n reservations:`
  91. compose_file += `\n devices:`
  92. compose_file += `\n - driver: nvidia`
  93. compose_file += `\n count: 1`
  94. compose_file += `\n capabilities: [gpu]`
  95. }
  96. }
  97. }
  98. }
  99. try {
  100. mkdirSync(`./appdata/${name}`, { recursive: true });
  101. writeFileSync(`./appdata/${name}/docker-compose.yml`, compose_file, function (err) { console.log(err) });
  102. exec(`docker compose -f ./appdata/${name}/docker-compose.yml up -d`, (error, stdout, stderr) => {
  103. if (error) { console.error(`error: ${error.message}`); return; }
  104. if (stderr) { console.error(`stderr: ${stderr}`); return; }
  105. console.log(`stdout:\n${stdout}`);
  106. });
  107. } catch { console.log('error creating directory or compose file') }
  108. }
  109. }
  110. module.exports.uninstall = async function (data) {
  111. if (req.session.role == "admin") {
  112. if (data.confirm == 'Yes') {
  113. exec(`docker compose -f ./appdata/${data.service_name}/docker-compose.yml down`, (error, stdout, stderr) => {
  114. if (error) { console.error(`error: ${error.message}`); return; }
  115. if (stderr) { console.error(`stderr: ${stderr}`); return; }
  116. console.log(`stdout:\n${stdout}`);
  117. });
  118. }
  119. // Redirect to the home page
  120. res.redirect("/");
  121. } else {
  122. // Redirect to the login page
  123. res.redirect("/login");
  124. }
  125. }