supabase-plus 0.8.13

An extra set of tools for managing Supabase projects going beyond the possibilities of regular Supabase CLI
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

use anyhow::Context;
use bollard::{Docker, query_parameters::ListContainersOptions, secret::ContainerSummary};

lazy_static::lazy_static! {
    pub static ref NO_DOCKER: String = crate::styled_error!(
        "It seems that either Docker isn't running or its socket/pipe file is broken"
    );
}

pub async fn supabase() -> anyhow::Result<Vec<ContainerSummary>> {
    let docker = Docker::connect_with_socket_defaults().with_context(|| NO_DOCKER.clone())?;

    Ok(docker
        .list_containers(None::<ListContainersOptions>)
        .await
        .context("It failed to get list of containers to identify Supabase projects, try restarting Docker, or reinstalling it if it doesn't help")?
        .into_iter()
        .filter(|container| {
            container
                .names
                .as_ref()
                .map(|indeed_names| {
                    indeed_names
                        .iter()
                        .any(|name| name.starts_with("/supabase_"))
                })
                .unwrap_or_default()
        })
        .collect())
}

pub async fn shadow_db() -> anyhow::Result<Option<ContainerSummary>> {
    let docker = Docker::connect_with_socket_defaults().with_context(|| NO_DOCKER.clone())?;

    let containers = docker
        .list_containers(None::<ListContainersOptions>)
        .await
        .context("It failed to get list of containers to identify Supabase projects, try restarting Docker, or reinstalling it if it doesn't help")?;

    for item in containers.into_iter() {
        let has_random_name = item
            .names
            .as_ref()
            .map(|indeed_names| {
                indeed_names
                    .iter()
                    .any(|name| !name.starts_with("/supabase_"))
            })
            .unwrap_or_default();

        if !has_random_name {
            continue;
        }

        let Some(ports) = item.ports.as_ref() else {
            continue;
        };

        let is_54320 = ports.iter().any(|item| item.public_port == Some(54320));

        if !is_54320 {
            continue;
        }

        let Some(image) = item.image.as_ref() else {
            continue;
        };

        if image.contains("supabase/postgres") {
            return Ok(Some(item));
        }
    }

    Ok(None)
}