summaryrefslogtreecommitdiff
path: root/src/sync.sh
blob: 5cc7a299f02b5b5f1e45b0590755c567a9d83536 (plain)
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
#!/bin/bash


# save each listed package in a relevant directory, based on checksum
#
parse_line() {
    local repo=$1
    local repo_url=$2
    local package=$3
    local checksum=$4
    local size=$5
    local files=$6

    local package_name=$(basename -s ".xipkg" $package)

    local package_dir="$PACKAGES_DIR/$repo/$package_name.versions"
    local checksum_file=$package_dir/$checksum

    [ -d $package_dir ] || mkdir -p $package_dir
    printf "$repo_url/$package $checksum $size $files\n" >> $checksum_file
}

list_source () {
    local repo=$1
    local src=$2

    local url=$(echo $src | cut -d":" -f2-)
    local name=$(echo $src | cut -d":" -f1)
    local repo_url="${url}${repo}"
    local full_url="${repo_url}/packages.list"
    local tmp_file="${SYNC_CACHE}/$name.$repo"

    local status=$(download_file $tmp_file $full_url)
    
    if [ "$status" = "200" ]; then
        while IFS= read -r line; do
            parse_line $repo $repo_url $line
        done < "$tmp_file"
    fi
}

dep_graph () {
    local src=$1
    local url=$(echo $src | cut -d":" -f2-)
    local name=$(echo $src | cut -d":" -f1)
    local full_url="${url}deps.graph"
    local tmp_file="${SYNC_CACHE}/$name.deps.graph"
    [ -f $tmp_file ] && rm $tmp_file; touch $tmp_file

    if [ "$(download_file $tmp_file $full_url)" = "200" ]; then
        while IFS= read -r line; do
            local package=$(echo $line | cut -d: -f1)
            local new=$(echo $line | cut -d: -f2-)
            echo $new >> $DEP_DIR/$package
        done < "$tmp_file"
    fi
}


contest () {
    local package_dir=$1

    local popular=$(wc -l $package_dir/* | sort -n | head -1 | awk '{ print $2 }' )

    local info_file=$(sed "s/.versions//g" <<< "$package_dir")
    mv $popular $info_file
    rm -r $package_dir
}

popularity_contest () {
    local list=$(ls -1 -d $PACKAGES_DIR/*/*)
    local total=$(echo $list | wc -l)

    for package_dir in $list; do
        contest $package_dir &
    done

    wait_for_jobs "${LARGE_CIRCLE} contesting packages..." "${CHECKMARK} contested packages"
}

index_deps () {
    local l=$1
    local total=${#SOURCES[*]}
    local completed=0

    for src in ${SOURCES[*]}; do
        dep_graph $src
        completed=$((completed+1))
        ${QUIET} || hbar -l $l -T "${LARGE_CIRCLE} indexing dependencies..." $completed $total
    done
    ${QUIET} || hbar -l $l ${HBAR_COMPLETE} -T "${CHECKMARK} indexed dependencies" $completed $total
}

index_repo () {
    local repo=$1 l=$2
    local total=${#SOURCES[*]}
    local completed=0

    for src in ${SOURCES[*]}; do
        list_source $repo $src 
        completed=$((completed+1))
        ${QUIET} || hbar -l $l -T "${LARGE_CIRCLE} syncing $repo..." $completed $total
    done
    ${QUIET} || hbar -l $l ${HBAR_COMPLETE} -T "${CHECKMARK} synced $repo" $completed $total
}


sync () {
    # prepare the file structure for the sync
    mkdir -p ${SYNC_CACHE}

    [ "$(ls -A $PACKAGES_DIR)" ] && rm -r $PACKAGES_DIR/*
    rm -r $DEP_DIR
    mkdir $DEP_DIR

    # create padding spaces for each hbar 
    ${QUIET} || for repo in ${REPOS[*]}; do 
        hbar
    done

    # download package lists and dep graphs at the same time
    index_deps 0 &
    local i=1
    for repo in ${REPOS[*]}; do 
        mkdir -p ${PACKAGES_DIR}/$repo
        index_repo $repo $i &
        i=$((i+1))
    done

    # wait for all jobs to complete
    wait

    # determine which version of which package should be regarded
    hbar
    popularity_contest
}