migrate 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. #!/usr/bin/python3
  2. import json
  3. import os
  4. import sys
  5. def storage_migrate(storage):
  6. delete_keys = []
  7. if storage['type'] == 'hostPath':
  8. # Check if the key exists, if not we have already migrated
  9. if not storage.get('hostPath'):
  10. return storage
  11. storage['hostPathConfig'] = {'hostPath': storage['hostPath']}
  12. delete_keys.append('hostPath')
  13. elif storage['type'] == 'ixVolume':
  14. # Check if the key exists, if not we have already migrated
  15. if not storage.get('datasetName'):
  16. return storage
  17. storage['ixVolumeConfig'] = {'datasetName': storage['datasetName']}
  18. delete_keys.append('datasetName')
  19. for key in delete_keys:
  20. storage.pop(key, None)
  21. return storage
  22. def migrate(values):
  23. storage_key = 'odooStorage'
  24. storages = ['data', 'addons', 'pgData', 'pgBackup']
  25. for storage in storages:
  26. check_val = values.get(storage_key, {}).get(storage, {})
  27. if not isinstance(check_val, dict) or not check_val:
  28. raise Exception(f'Storage section {storage} is malformed')
  29. values[storage_key][storage] = storage_migrate(check_val)
  30. return values
  31. if __name__ == '__main__':
  32. if len(sys.argv) != 2:
  33. exit(1)
  34. if os.path.exists(sys.argv[1]):
  35. with open(sys.argv[1], 'r') as f:
  36. print(json.dumps(migrate(json.loads(f.read()))))