Compare commits
	
		
			12 Commits
		
	
	
		
			4cf11798aa
			...
			cyberia-pr
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 5a67a58f98 | |||
| 3346a45ed4 | |||
| f8e187ff84 | |||
| ba997bb3ff | |||
| f3630fbacf | |||
| f94d3aa1d3 | |||
| a9c4ae7572 | |||
| dc8da3170b | |||
| 59b72adefb | |||
| c6380f292f | |||
| dbe75dd868 | |||
| ae5f57645f | 
| @ -142,8 +142,12 @@ app.config['HTTP_CLIENT'] = MyHTTPClient(timeout_seconds=int(app.config['INTERNA | |||||||
| app.config['BTCPAY_ENABLED'] = False | app.config['BTCPAY_ENABLED'] = False | ||||||
| if app.config['BTCPAY_URL'] != "": | if app.config['BTCPAY_URL'] != "": | ||||||
|   try: |   try: | ||||||
|     app.config['BTCPAY_CLIENT'] = btcpay.Client(api_uri=app.config['BTCPAY_URL'], pem=app.config['BTCPAY_PRIVATE_KEY']) |     response = requests.get(app.config['BTCPAY_URL']) | ||||||
|     app.config['BTCPAY_ENABLED'] = True |     if response.status_code == 200: | ||||||
|  |       app.config['BTCPAY_CLIENT'] = btcpay.Client(api_uri=app.config['BTCPAY_URL'], pem=app.config['BTCPAY_PRIVATE_KEY']) | ||||||
|  |       app.config['BTCPAY_ENABLED'] = True | ||||||
|  |     else: | ||||||
|  |       app.logger.warning(f"Can't reach BTCPAY_URL {app.config['BTCPAY_URL']}: Response status code: {response.status_code}. Capsul will work fine except cryptocurrency payments will not work.") | ||||||
|   except: |   except: | ||||||
|     app.logger.warning("unable to create btcpay client. Capsul will work fine except cryptocurrency payments will not work. The error was: " + my_exec_info_message(sys.exc_info())) |     app.logger.warning("unable to create btcpay client. Capsul will work fine except cryptocurrency payments will not work. The error was: " + my_exec_info_message(sys.exc_info())) | ||||||
|  |  | ||||||
|  | |||||||
| @ -62,6 +62,18 @@ def sql_script(f, c): | |||||||
|  |  | ||||||
|     model.connection.commit() |     model.connection.commit() | ||||||
|  |  | ||||||
|  | @bp.cli.command('account-balance') | ||||||
|  | @click.option('-u', help='users email address') | ||||||
|  | @with_appcontext | ||||||
|  | def account_balance(u): | ||||||
|  |   vms = get_model().list_vms_for_account(u) | ||||||
|  |   payments = get_model().list_payments_for_account(u) | ||||||
|  |   click.echo(".") | ||||||
|  |   click.echo(".") | ||||||
|  |   click.echo(get_account_balance(vms, payments, datetime.utcnow())) | ||||||
|  |   click.echo(".") | ||||||
|  |  | ||||||
|  |  | ||||||
|  |  | ||||||
| @bp.cli.command('cron-task') | @bp.cli.command('cron-task') | ||||||
| @with_appcontext | @with_appcontext | ||||||
|  | |||||||
| @ -43,7 +43,7 @@ def init_app(app, is_running_server): | |||||||
|   hasSchemaVersionTable = False |   hasSchemaVersionTable = False | ||||||
|   actionWasTaken = False |   actionWasTaken = False | ||||||
|   schemaVersion = 0 |   schemaVersion = 0 | ||||||
|   desiredSchemaVersion = 18 |   desiredSchemaVersion = 20 | ||||||
|  |  | ||||||
|   cursor = connection.cursor() |   cursor = connection.cursor() | ||||||
|  |  | ||||||
|  | |||||||
| @ -228,8 +228,8 @@ class CapsulFlaskHub(VirtualizationInterface): | |||||||
|         # no need to do anything here since if it cant be parsed then generic_operation will handle it. |         # no need to do anything here since if it cant be parsed then generic_operation will handle it. | ||||||
|         pass |         pass | ||||||
|        |        | ||||||
|  |     assigned_hosts_string = ", ".join(assigned_hosts) | ||||||
|     if number_of_assigned != 1: |     if number_of_assigned != 1: | ||||||
|       assigned_hosts_string = ", ".join(assigned_hosts) |  | ||||||
|       raise ValueError(f"expected create capsul operation {operation_id} to be assigned to one host, it was assigned to {number_of_assigned} ({assigned_hosts_string})") |       raise ValueError(f"expected create capsul operation {operation_id} to be assigned to one host, it was assigned to {number_of_assigned} ({assigned_hosts_string})") | ||||||
|     if error_message != "": |     if error_message != "": | ||||||
|       raise ValueError(f"create capsul operation {operation_id} on {assigned_hosts_string} failed with {error_message}") |       raise ValueError(f"create capsul operation {operation_id} on {assigned_hosts_string} failed with {error_message}") | ||||||
|  | |||||||
| @ -58,14 +58,19 @@ def btcpay_payment(): | |||||||
|     dollars = result[1] |     dollars = result[1] | ||||||
|  |  | ||||||
|     if len(errors) == 0: |     if len(errors) == 0: | ||||||
|       invoice = current_app.config['BTCPAY_CLIENT'].create_invoice(dict( |       try: | ||||||
|         price=float(dollars),  |         invoice = current_app.config['BTCPAY_CLIENT'].create_invoice(dict( | ||||||
|         currency="USD", |           price=float(dollars),  | ||||||
|         itemDesc="Capsul Cloud Compute", |           currency="USD", | ||||||
|         transactionSpeed="high", |           itemDesc="Capsul Cloud Compute", | ||||||
|         redirectURL=f"{current_app.config['BASE_URL']}/console/account-balance", |           transactionSpeed="high", | ||||||
|         notificationURL=f"{current_app.config['BASE_URL']}/payment/btcpay/webhook" |           redirectURL=f"{current_app.config['BASE_URL']}/console/account-balance", | ||||||
|       )) |           notificationURL=f"{current_app.config['BASE_URL']}/payment/btcpay/webhook" | ||||||
|  |         )) | ||||||
|  |       except: | ||||||
|  |         current_app.logger.error(f"An error occurred while attempting to reach BTCPay Server: {my_exec_info_message(sys.exc_info())}") | ||||||
|  |         flash("An error occurred while attempting to reach BTCPay Server.") | ||||||
|  |         return redirect(url_for("console.account_balance")) | ||||||
|  |  | ||||||
|       current_app.logger.info(f"created btcpay invoice: {invoice}") |       current_app.logger.info(f"created btcpay invoice: {invoice}") | ||||||
|  |  | ||||||
|  | |||||||
							
								
								
									
										8
									
								
								capsulflask/schema_migrations/19_down_os_updates.sql
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										8
									
								
								capsulflask/schema_migrations/19_down_os_updates.sql
									
									
									
									
									
										Normal file
									
								
							| @ -0,0 +1,8 @@ | |||||||
|  | DELETE FROM os_images WHERE id = 'guixsystem130'; | ||||||
|  | DELETE FROM os_images WHERE id = 'archlinux'; | ||||||
|  | UPDATE os_images SET deprecated = FALSE WHERE id = 'guixsystem120'; | ||||||
|  | UPDATE os_images SET deprecated = FALSE WHERE id = 'centos7'; | ||||||
|  | UPDATE os_images SET deprecated = FALSE WHERE id = 'centos8'; | ||||||
|  | UPDATE os_images SET description = 'Ubuntu 20.04 LTS (Fossa)' WHERE id = 'ubuntu20'; | ||||||
|  |  | ||||||
|  | UPDATE schemaversion SET version = 18; | ||||||
							
								
								
									
										12
									
								
								capsulflask/schema_migrations/19_up_os_updates.sql
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										12
									
								
								capsulflask/schema_migrations/19_up_os_updates.sql
									
									
									
									
									
										Normal file
									
								
							| @ -0,0 +1,12 @@ | |||||||
|  | INSERT INTO os_images (id, template_image_file_name, description, deprecated) | ||||||
|  | VALUES  ('guixsystem130', 'guixsystem/1.3.0/root.img.qcow2', 'Guix System 1.3.0', FALSE); | ||||||
|  | INSERT INTO os_images (id, template_image_file_name, description, deprecated) | ||||||
|  | VALUES  ('archlinux', 'archlinux/root.img.qcow2', 'Arch Linux', FALSE); | ||||||
|  |  | ||||||
|  | UPDATE os_images SET deprecated = TRUE WHERE id = 'guixsystem120'; | ||||||
|  | UPDATE os_images SET deprecated = TRUE WHERE id = 'centos7'; | ||||||
|  | UPDATE os_images SET deprecated = TRUE WHERE id = 'centos8'; | ||||||
|  | UPDATE os_images SET description = 'Ubuntu 20.04 (Focal)' WHERE id = 'ubuntu20'; | ||||||
|  |  | ||||||
|  |  | ||||||
|  | UPDATE schemaversion SET version = 19; | ||||||
| @ -0,0 +1,21 @@ | |||||||
|  |  | ||||||
|  | ALTER TABLE host_network ALTER CONSTRAINT host_network_host_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE host_operation ALTER CONSTRAINT host_operation_host_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE host_operation ALTER CONSTRAINT host_operation_operation_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE login_tokens ALTER CONSTRAINT login_tokens_email_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE operations ALTER CONSTRAINT operations_email_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE payment_sessions ALTER CONSTRAINT payment_sessions_email_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE payments ALTER CONSTRAINT payments_email_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE ssh_public_keys ALTER CONSTRAINT ssh_public_keys_email_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE unresolved_btcpay_invoices ALTER CONSTRAINT unresolved_btcpay_invoices_email_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE unresolved_btcpay_invoices ALTER CONSTRAINT unresolved_btcpay_invoices_email_payment_id_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE vm_ssh_authorized_key ALTER CONSTRAINT vm_ssh_public_key_email_ssh_public_key_name_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE vm_ssh_authorized_key ALTER CONSTRAINT vm_ssh_public_key_email_vm_id_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE vm_ssh_host_key ALTER CONSTRAINT vm_ssh_host_key_email_vm_id_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_email_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_host_network_name_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_host_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_os_fkey NOT DEFERRABLE; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_size_fkey NOT DEFERRABLE; | ||||||
|  |  | ||||||
|  | UPDATE schemaversion SET version = 19; | ||||||
| @ -0,0 +1,21 @@ | |||||||
|  |  | ||||||
|  | ALTER TABLE host_network ALTER CONSTRAINT host_network_host_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE host_operation ALTER CONSTRAINT host_operation_host_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE host_operation ALTER CONSTRAINT host_operation_operation_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE login_tokens ALTER CONSTRAINT login_tokens_email_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE operations ALTER CONSTRAINT operations_email_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE payment_sessions ALTER CONSTRAINT payment_sessions_email_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE payments ALTER CONSTRAINT payments_email_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE ssh_public_keys ALTER CONSTRAINT ssh_public_keys_email_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE unresolved_btcpay_invoices ALTER CONSTRAINT unresolved_btcpay_invoices_email_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE unresolved_btcpay_invoices ALTER CONSTRAINT unresolved_btcpay_invoices_email_payment_id_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE vm_ssh_authorized_key ALTER CONSTRAINT vm_ssh_public_key_email_ssh_public_key_name_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE vm_ssh_authorized_key ALTER CONSTRAINT vm_ssh_public_key_email_vm_id_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE vm_ssh_host_key ALTER CONSTRAINT vm_ssh_host_key_email_vm_id_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_email_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_host_network_name_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_host_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_os_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  | ALTER TABLE vms ALTER CONSTRAINT vms_size_fkey DEFERRABLE INITIALLY DEFERRED; | ||||||
|  |  | ||||||
|  | UPDATE schemaversion SET version = 20; | ||||||
| @ -182,7 +182,10 @@ def handle_destroy(operation_id, request_body): | |||||||
|     return abort(400, f"bad request; email is required for destroy") |     return abort(400, f"bad request; email is required for destroy") | ||||||
|  |  | ||||||
|   try: |   try: | ||||||
|     current_app.config['SPOKE_MODEL'].destroy(id=request_body['id'], email=request_body['email']) |     vm = current_app.config['SPOKE_MODEL'].get(request_body['id'], False) | ||||||
|  |     current_app.logger.warning(f"destroy {request_body['id']} was called for {request_body['email']}, however the vm does not exist. returning success. ") | ||||||
|  |     if vm is not None: | ||||||
|  |       current_app.config['SPOKE_MODEL'].destroy(id=request_body['id'], email=request_body['email']) | ||||||
|   except: |   except: | ||||||
|     error_message = my_exec_info_message(sys.exc_info()) |     error_message = my_exec_info_message(sys.exc_info()) | ||||||
|     params =          f"email='{request_body['email'] if 'email' in request_body else 'KeyError'}', " |     params =          f"email='{request_body['email'] if 'email' in request_body else 'KeyError'}', " | ||||||
|  | |||||||
| @ -7,18 +7,11 @@ | |||||||
|     <h1>SUPPORT</h1> |     <h1>SUPPORT</h1> | ||||||
|   </div> |   </div> | ||||||
|   <div class="row half-margin"> |   <div class="row half-margin"> | ||||||
|     <a href="mailto:support@cyberia.club?subject=Please%20help!">support@cyberia.club</a>  |     <a href="mailto:support@cyberia.club?subject=capsul%20support%20request">support@cyberia.club</a> | ||||||
|   </div> |   </div> | ||||||
| {% endblock %} | {% endblock %} | ||||||
|  |  | ||||||
| {% block subcontent %} | {% block subcontent %} | ||||||
| <p> |  | ||||||
|   Note: We maintain a searchable archive of all support emails at  |  | ||||||
|   <a href="https://lists.cyberia.club/~cyberia/support">https://lists.cyberia.club/~cyberia/support</a> |  | ||||||
| </p> |  | ||||||
| <p> |  | ||||||
|   If you do not want your mail to appear in a public archive, email <a href="mailto:capsul@cyberia.club?subject=Please%20help!">capsul@cyberia.club</a> instead. |  | ||||||
| </p> |  | ||||||
| <p> | <p> | ||||||
|   Please describe your problem or feature request, and we will do our best to get back to you promptly. Thank you very much. |   Please describe your problem or feature request, and we will do our best to get back to you promptly. Thank you very much. | ||||||
| </p> | </p> | ||||||
|  | |||||||
| @ -48,3 +48,20 @@ $ pipenv run flask cli sql -c "SELECT id, created, email, dollars, invalidated f | |||||||
| ## how to view the logs on the database server (legion.cyberia.club) | ## how to view the logs on the database server (legion.cyberia.club) | ||||||
|  |  | ||||||
| `sudo -u postgres pg_dump capsul-flask | gzip -9 > capsul-backup-2021-02-15.gz` | `sudo -u postgres pg_dump capsul-flask | gzip -9 > capsul-backup-2021-02-15.gz` | ||||||
|  |  | ||||||
|  |  | ||||||
|  | ## changing the email address on an account | ||||||
|  |  | ||||||
|  | ``` | ||||||
|  | UPDATE accounts SET lower_case_email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE accounts SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE login_tokens SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE operations SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE payment_sessions SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE payments SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE ssh_public_keys SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE unresolved_btcpay_invoices SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE vm_ssh_authorized_key SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE vm_ssh_host_key SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | UPDATE vms SET email = 'new@email.address' WHERE email = 'old@email.address' ; | ||||||
|  | ``` | ||||||
|  | |||||||
		Reference in New Issue
	
	Block a user