mirror of
https://github.com/neondatabase/neon.git
synced 2026-01-16 18:02:56 +00:00
actually write correct data
This commit is contained in:
1
alek/env.txt
Normal file
1
alek/env.txt
Normal file
@@ -0,0 +1 @@
|
||||
{'repo_dir': PosixPath('/home/alek/Desktop/neonX/test_output/test_file_download[debug-pg14]/repo'), 'rust_log_override': None, 'port_distributor': <fixtures.neon_fixtures.PortDistributor object at 0x7f500e15f130>, 's3_mock_server': <fixtures.neon_fixtures.MockS3Server object at 0x7f500e15ed70>, 'neon_cli': <fixtures.neon_fixtures.NeonCli object at 0x7f500c6c7af0>, 'endpoints': <fixtures.neon_fixtures.EndpointFactory object at 0x7f500c6c7a60>, 'safekeepers': [Safekeeper(env=<fixtures.neon_fixtures.NeonEnv object at 0x7f500c6c7a90>, port=SafekeeperPort(pg=15007, http=15008), id=1, running=True), Safekeeper(env=<fixtures.neon_fixtures.NeonEnv object at 0x7f500c6c7a90>, port=SafekeeperPort(pg=15009, http=15010), id=2, running=True), Safekeeper(env=<fixtures.neon_fixtures.NeonEnv object at 0x7f500c6c7a90>, port=SafekeeperPort(pg=15011, http=15012), id=3, running=True)], 'broker': NeonBroker(logfile=PosixPath('/home/alek/Desktop/neonX/test_output/test_file_download[debug-pg14]/repo/storage_broker.log'), port=15004, neon_binpath=PosixPath('/home/alek/Desktop/neonX/target/debug'), handle=<Popen: returncode: None args: ['/home/alek/Desktop/neonX/target/debug/stora...>), 'remote_storage': S3Storage(bucket_name='test_file_download', bucket_region='us-east-1', access_key='test', secret_key='test', endpoint='http://127.0.0.1:15003', prefix_in_bucket=None), 'remote_storage_users': <RemoteStorageUsers.PAGESERVER: 1>, 'pg_version': '14', 'neon_binpath': PosixPath('/home/alek/Desktop/neonX/target/debug'), 'pg_distrib_dir': PosixPath('/home/alek/Desktop/neonX/pg_install'), 'endpoint_counter': 0, 'initial_tenant': `TenantId("861cf3b88b5e53ac412227ed9fd26d10"), 'initial_timeline': TimelineId("04179cf8c30a9d3652cd39d790b4e4b7"), 'pageserver': <fixtures.neon_fixtures.NeonPageserver object at 0x7f500c6c7970>}
|
||||
1
alek/output.txt
Normal file
1
alek/output.txt
Normal file
@@ -0,0 +1 @@
|
||||
NoneNone
|
||||
5
alek/test_ext.control
Normal file
5
alek/test_ext.control
Normal file
@@ -0,0 +1,5 @@
|
||||
# mock extension
|
||||
comment = 'Mock extension'
|
||||
default_version = '1.0'
|
||||
module_pathname = '$libdir/test_ext'
|
||||
relocatable = true
|
||||
@@ -35,7 +35,7 @@ def test_file_download(neon_env_builder: NeonEnvBuilder):
|
||||
neon_env_builder.num_safekeepers = 3
|
||||
env = neon_env_builder.init_start()
|
||||
|
||||
with open("loggg", "w") as f:
|
||||
with open("alek/env.txt", "w") as f:
|
||||
f.write(str(env.__dict__))
|
||||
|
||||
TEST_EXT_PATH = "v15/share/extension/test_ext.control"
|
||||
@@ -45,7 +45,7 @@ def test_file_download(neon_env_builder: NeonEnvBuilder):
|
||||
|
||||
# 4. Upload test_ext.control file to the bucket
|
||||
# Later this will be done by CI/CD
|
||||
with open("test_ext.control", "rb") as data:
|
||||
with open("alek/test_ext.control", "rb") as data:
|
||||
neon_env_builder.remote_storage_client.upload_fileobj(
|
||||
data, neon_env_builder.remote_storage.bucket_name, TEST_EXT_PATH
|
||||
)
|
||||
@@ -55,10 +55,9 @@ def test_file_download(neon_env_builder: NeonEnvBuilder):
|
||||
resp = neon_env_builder.remote_storage_client.get_object(
|
||||
Bucket=neon_env_builder.remote_storage.bucket_name, Key=TEST_EXT_PATH
|
||||
)
|
||||
content_length = resp["ResponseMetadata"]["HTTPHeaders"]["content-length"]
|
||||
# TODO: this is not the correct path, nor the correct data to write
|
||||
with open("pg_install/v15/lib/test_ext.control", "w") as f:
|
||||
f.write(str(resp))
|
||||
response = resp["Body"]
|
||||
with open("pg_install/v15/lib/test_ext.control", "wb") as f:
|
||||
f.write(response.read())
|
||||
|
||||
# env.neon_cli
|
||||
|
||||
@@ -72,7 +71,7 @@ def test_file_download(neon_env_builder: NeonEnvBuilder):
|
||||
# TODO: we should see the test_ext extension here
|
||||
other = cur.execute("SELECT * FROM pg_catalog.pg_tables;")
|
||||
whatsup = cur.execute("select * from pg_available_extensions;")
|
||||
with open("output.txt", "w") as f:
|
||||
with open("alek/output.txt", "w") as f:
|
||||
f.write(str(whatsup) + str(other))
|
||||
# this is returning None????
|
||||
|
||||
|
||||
Reference in New Issue
Block a user