From 4db13cdd6eaade5ce5ccf32ec3b1625a5bdb220a Mon Sep 17 00:00:00 2001 From: Chewing_Bever Date: Wed, 8 Feb 2023 10:43:33 +0100 Subject: [PATCH] chore: ran v fmt for v 0.3.3 changes --- containers.v | 14 +++++++------- docker.v | 6 +++--- images.v | 10 +++++----- request.v | 12 ++++++------ util/util.v | 2 +- volumes.v | 2 +- 6 files changed, 23 insertions(+), 23 deletions(-) diff --git a/containers.v b/containers.v index 6981a2c..c119f9e 100644 --- a/containers.v +++ b/containers.v @@ -16,7 +16,7 @@ pub fn (mut d DockerConn) container_list(c ContainerListConfig) ![]ContainerList d.params(c) d.send()! - return d.read_json_response<[]ContainerListItem>() + return d.read_json_response[[]ContainerListItem]() } pub struct NewContainer { @@ -39,12 +39,12 @@ pub fn (mut d DockerConn) container_create(c NewContainer) !CreatedContainer { d.body_json(c) d.send()! - return d.read_json_response() + return d.read_json_response[CreatedContainer]() } // start_container starts the container with the given id. pub fn (mut d DockerConn) container_start(id string) ! { - d.request(.post, '/containers/$id/start') + d.request(.post, '/containers/${id}/start') d.send()! d.read_response()! } @@ -68,10 +68,10 @@ pub mut: } pub fn (mut d DockerConn) container_inspect(id string) !ContainerInspect { - d.request(.get, '/containers/$id/json') + d.request(.get, '/containers/${id}/json') d.send()! - mut data := d.read_json_response()! + mut data := d.read_json_response[ContainerInspect]()! // The Docker engine API *should* always return UTC time. data.state.start_time = time.parse_rfc3339(data.state.start_time_str)! @@ -84,13 +84,13 @@ pub fn (mut d DockerConn) container_inspect(id string) !ContainerInspect { } pub fn (mut d DockerConn) container_remove(id string) ! { - d.request(.delete, '/containers/$id') + d.request(.delete, '/containers/${id}') d.send()! d.read_response()! } pub fn (mut d DockerConn) container_get_logs(id string) !&StreamFormatReader { - d.request(.get, '/containers/$id/logs') + d.request(.get, '/containers/${id}/logs') d.params({ 'stdout': 'true' 'stderr': 'true' diff --git a/docker.v b/docker.v index cd30b60..2a3458b 100644 --- a/docker.v +++ b/docker.v @@ -81,7 +81,7 @@ fn (mut d DockerConn) read_response_body() ! { content_length := d.head.header.get(.content_length)!.int() if content_length == 0 { - d.body = '' + d.body = '' return } @@ -111,7 +111,7 @@ fn (mut d DockerConn) read_response() ! { // read_json_response is a convenience function that runs read_response // before parsing its contents, which is assumed to be JSON, into a struct. -fn (mut d DockerConn) read_json_response() !T { +fn (mut d DockerConn) read_json_response[T]() !T { d.read_response()! data := json.decode(T, d.body)! @@ -156,6 +156,6 @@ fn (mut d DockerConn) check_error() ! { d.read_response_body()! d_err := json.decode(DockerError, d.body)! - return error_with_code('$d.head.status(): $d_err.message', d.head.status_code) + return error_with_code('${d.head.status()}: ${d_err.message}', d.head.status_code) } } diff --git a/images.v b/images.v index 76df20d..016a1dd 100644 --- a/images.v +++ b/images.v @@ -3,10 +3,10 @@ module docker import types { Image } pub fn (mut d DockerConn) image_inspect(image string) !Image { - d.request(.get, '/images/$image/json') + d.request(.get, '/images/${image}/json') d.send()! - data := d.read_json_response()! + data := d.read_json_response[Image]()! return data } @@ -42,18 +42,18 @@ pub fn (mut d DockerConn) image_from_container(id string, repo string, tag strin }) d.send()! - return d.read_json_response()! + return d.read_json_response[Image]()! } // remove_image removes the image with the given id. pub fn (mut d DockerConn) image_remove(id string) ! { - d.request(.delete, '/images/$id') + d.request(.delete, '/images/${id}') d.send()! d.read_response()! } pub fn (mut d DockerConn) image_tag(name string, repo string, tag string) ! { - d.request(.post, '/images/$name/tag') + d.request(.post, '/images/${name}/tag') d.params({ 'repo': repo 'tag': tag diff --git a/request.v b/request.v index 92d7073..7138778 100644 --- a/request.v +++ b/request.v @@ -19,12 +19,12 @@ fn (mut d DockerConn) body(content_type string, body string) { d.body = body } -fn (mut d DockerConn) body_json(data T) { +fn (mut d DockerConn) body_json[T](data T) { d.content_type = 'application/json' d.body = json.encode(data) } -fn (mut d DockerConn) params(o T) { +fn (mut d DockerConn) params[T](o T) { $if T is map[string]string { for key, value in o { d.params[key] = urllib.query_escape(value.replace("'", '"')) @@ -44,8 +44,8 @@ fn (mut d DockerConn) send() ! { mut full_url := d.url if d.params.len > 0 { - params_str := d.params.keys().map('$it=${d.params[it]}').join('&') - full_url += '?$params_str' + params_str := d.params.keys().map('${it}=${d.params[it]}').join('&') + full_url += '?${params_str}' } // This is to make sure we actually created a valid URL @@ -53,9 +53,9 @@ fn (mut d DockerConn) send() ! { final_url := parsed_url.request_uri() req := if d.body == '' { - '$d.method $final_url HTTP/1.1\nHost: localhost\n\n' + '${d.method} ${final_url} HTTP/1.1\nHost: localhost\n\n' } else { - '$d.method $final_url HTTP/1.1\nHost: localhost\nContent-Type: $d.content_type\nContent-Length: $d.body.len\n\n$d.body\n\n' + '${d.method} ${final_url} HTTP/1.1\nHost: localhost\nContent-Type: ${d.content_type}\nContent-Length: ${d.body.len}\n\n${d.body}\n\n' } d.socket.write_string(req)! diff --git a/util/util.v b/util/util.v index 1181480..e905a9f 100644 --- a/util/util.v +++ b/util/util.v @@ -21,7 +21,7 @@ pub fn reader_to_writer(mut reader io.Reader, mut writer io.Writer) ! { // match_array_in_array returns how many elements of a2 overlap with a1. For // example, if a1 = "abcd" & a2 = "cd", the result will be 2. If the match is // not at the end of a1, the result is 0. -pub fn match_array_in_array(a1 []T, a2 []T) int { +pub fn match_array_in_array[T](a1 []T, a2 []T) int { mut i := 0 mut match_len := 0 diff --git a/volumes.v b/volumes.v index be648c8..69e619b 100644 --- a/volumes.v +++ b/volumes.v @@ -20,7 +20,7 @@ pub fn (mut d DockerConn) volume_list() !VolumeListResponse { d.request(.get, '/volumes') d.send()! - mut data := d.read_json_response()! + mut data := d.read_json_response[VolumeListResponse]()! for mut vol in data.volumes { vol.created_at = time.parse_rfc3339(vol.created_at_str)!