Запись [f:_dev/util/scripts.php] < dev.sky.1.001

<?php defined('START') and AUTH_OK or die;
 
if (START == 'ajax'):
 
function _opt($str) {
    for ($out = ''; strlen($str) > 100; $str = substr($str, $pos + 1)) {
        $pos = strrpos(substr($str, 0, 100), ' ');
        if (!$pos) $pos = strpos($str, ' ', 2);
        if (!$pos) break;
        $out .= substr($str, 0, $pos)."\n";
    }
    return trim($out . $str);
}
 
function write_cb(&$id, $new, $name = 0) {
    global $tpl_insert, $eid;
    $name === 0 or list($x, $fn) = explode(':', $name);
    $r = sql("@select code from _dev_codebase where id in ($eid, $id) order by id");
    $r0 = str2cnt($r[0]);
    if (2 == count($r)) $r1 = str2cnt($r[1]);
    $n = str2cnt($new);
    if (!$name || $x == 'f' && $n < 20 && $n + $r0 < 700 || $x != 'f' && $n < 250 && $n + $r0 < 700) {
        $nl = $r[0] === '' ? '' : "\n\n";
        if ($name === 0) $new = "$new$nl$r[0]";
        else $new = $x == 'f' ? "# WRITE FILE: $fn #\n$new$nl$r[0]" : "$r[0]$nl$new";
        sqlf("update _dev_codebase set code=%s where id=$eid", escape($new));
    } elseif (2 == count($r) && $n + $r1 < 1000) {
        if ($x == 'f') $new = "# WRITE FILE: $fn #\n$new";
        sqlf("update _dev_codebase set code=%s where id=$id", escape("$r[1]\n\n$new"));
    } else {
        if ($id != $eid) sql("update _dev_codebase set code=concat(code,'\n\n# END:  #') where id=$id");
        return ',' . ($id = sqlf($tpl_insert, $name, escape($new)));
    }
    return '';
}
 
function on_error() {
    global $eid;
    if (@$eid > 50000) sql("delete from _dev_codebase where id>=$eid");
}
 
eval($memory = get('ini' == PAGE));
 
switch ($step):
case 1: # init
    $tpl_select = "select %s from _dev_memory where id>1000 and imemo=$PVAL and code";
    eval($vars = $PVAL ? sqlf("+$tpl_select=-1", 'tmemo') : cell(88));
    $PVAL ? set('u_nupd', ++$u_nupd, 2) : set('u_napp', ++$u_napp, 2); # 2do: setup var from server!
    $q = sql("select
            m.id, m.code as cb_id, m.imemo as pk_id, m.cmemo, m.tmemo as mtm,
            p.version as pv, p.name as pn, p.status
        from _dev_memory m
    --        left join _dev_codebase c on (c.id = m.code)   2del ?
            left join _dev_packages p on (p.id = m.imemo)
        where m.id>499 and m.id<1000 order by m.id");
    for ($dep = $inc = $pri = $del = [], $builds = str2ary($builds); eval(fetch); ) {
        if (!$r_pn) echo_json("-Error: in dependencies. Stop.", true);
        $name_ver = ver($r_pv, $r_pn);
        $is_old = in_array($r_cb_id, $builds);
        $depend = 0;
        eval($r_mtm);
        if (!$sky_id) echo_json("-Error: no SKY_ID for build [$r_cb_id]$name_ver, stop.", true);
        if (1 == $r_cb_id) {
            $dep[] = $name_ver;
            $dev_ok = '11' == substr($r_status, 0, 2);
        } elseif ($r_cb_id <= 10000) {
            if ($is_old) $pri[] = "[$r_cb_id]$r_cmemo";
            $del[] = $r_id;
        } else {
            if ($is_old) {
                $dep[] = $r_cmemo;
                $depend = $r_pk_id;
            } else {
                foreach (str2ary($priorun) as $one) if (in_array((int)substr($one, 1), $builds)) $pri[] = $one;
                $inc[] = $r_cmemo;
                $del[] = $r_id;
            }
        }
        if ($depend && $run_changed) echo_json("-Error: Package `$name_ver` run modified, cannot set depends. Stop.", true);
    }
    if (!$dep || 'dev.sky.' != substr($dep[0], 0, 8)) echo_json("-Error: Error in dependence of dev.sky. Stop.", true);
    if ($pri && 'dev.sky.' != $u_my_app && !$dev_ok) echo_json("-Error: DEV changed when priorun exist. Stop.", true);
    if (!$inc && 1 == count($dep) && 'a' == $p_t) $inc[] = 'scratch work';
    elseif (!$inc || $p_w) $inc[] = 'work';
    $tpl_insert = "insert into _dev_codebase values(null, '%s', 1, 0, $u_my_rubric, 0, '1 0 0 00000 t 01', now(), now(), %s, '$u_sky_inet_login', 1, %s, null, %s)";
    area($syn, $area);
    set($area + [
        'step' => 2, 'start' => START_TS,
        'k_name' => $p_n, 'k_rubric' => $u_my_rubric, 'k_lang' => 'en', 'k_type' => $p_t,
        'facnt=tacnt=racnt=fdcnt=tdcnt=rdcnt=fecnt=tecnt=recnt=i_dir=i_file=fsize=fcnt=rcnt' => 0,
        'author' => $u_sky_inet_login,
        'eid=cid=fid=rid' => $eid = sqlf($tpl_insert, $PVAL ? "u:$p_n" : "a:$p_n", "''", 'null', "'(enter point)'"),
        'tpl_insert' => sprintf($tpl_insert, '%s', '%s', "',$eid,'", 'null'),
        'tpl_select' => $tpl_select,
        'sql_update' => "update _dev_memory set cmemo=mid(cmemo,2) where id>1000 and imemo=$PVAL and code=0 and left(cmemo,1)='.'",
        'priorun' => implode(' ', $pri), 'depends' => implode(' ', $dep), 'included' => implode(' ', $inc), 'del_builds' => implode(',', $del),
    ], [$vars]);
    $log = '1. Script creation from ' . ($PVAL ? "Snapshot ID=$PVAL" : 'Scratch') . ' started.';
    # if ($opt) $log .= sprintf(span_g, ' Definitions optimized for you by fix_def() function.');
    $log .= "\n2. Processing files:";
    break;
case 2:
    $u_text_files || echo_json("-Fail. \$u_text_files can't be empty", true);
    $area = @area();
    list($dirs_new, $skip, $nused, $files3) = filter_path($area->inc_p, $area->exc_p);
    set([
        'dirs' => implode(' ', $dirs_old = array_filter(str2ary($dirs), 'match_path')),
        'add' => implode(' ', array_diff($dirs_new, $dirs_old)),
        'del' => implode(' ', array_diff($dirs_old, $dirs_new)),
        'skip' => implode(' ', $skip),
        'files3' => implode(' ', $files3),
        'step'   => 3, 'addid' => '', '' => "\n#",
    ]);
    break;
case 3:
    $dirs = array_merge(str2ary($dirs), $add = str2ary($add));
    if ($i_dir < count($dirs)) {
        if ($i_file) $files = str2ary($files); else {
            $files = is_file($dir = $dirs[$i_dir]) ? [$dir] : Area::lst($dir, 'is_file', false, $skip);
            $ary = ['files' => implode(' ', $files)] + $ary;
        }
        if ($i_file < count($files)) {
            if (!in_array(basename($fn = $files[$i_file]), $u_svn_skips)) {
                $err = "\nScript not complete, please <a href=\"?cb_list\">delete it</a>.";
                if (is_array($file = getfile($fn, $ftype = rectype($fn)))) echo_json("-Fail. $file[0]$err", true);
                $ary += ['fcnt' => ++$fcnt, 'fsize' => $fsize + filesize($fn)];
                $r = 0;
                if ($sid && eval(sqlf("^$tpl_select>0 and cmemo='$fn'", 'tmemo, title'))) {
                    if ($ftype == 1 && $r_title > 400) $r_tmemo = bzdecompress(base64_decode($r_tmemo));
                    require '_dev/main/diff.php';
                    if ($c = script_diff("FILE: $fn", $file, $r_tmemo, $ftype)) {
                        $addid .= write_cb($cid, $c, 'u:' . basename($fn));
                        $ary += ['fecnt' => ++$fecnt];
                        $log = "  $fn - file changed";
                    } elseif ($c === '') $log = '.'; # identical
                    else $ary += ['' => " $fn", 'fecnt' => ++$fecnt] and $log = sprintf(span_b, "  $fn - file overwritten");
                } else $ary += ['facnt' => ++$facnt] and $log = sprintf(span_g, "  $fn - file added");
                if (!$r || $c === 0) $addid .= write_cb($fid, sp2tabs(cbesc($file)), "f:$fn");
            }
            $i_file++;
        } else {
            $i_file = 0;
            $dir = $dirs[$i_dir++];
            if ($sid && !in_array($dir, $add)) { # search for deleted files
                if ('.' == $dir) $cmemo = "rlike '^[^/]+$'"; else $cmemo = is_file($dir) ? "='$dir'" : "rlike '^$dir/[^/]+$'";
                $skip = str2ary($skip);
                $area = @area(); # for match_path()
                if ($del = array_filter(array_diff(sqlf("@$tpl_select>0 and cmemo $cmemo", 'cmemo'), $files), 'match_path')) {
                    $ary += ['' => ' ' . implode(' ', $del), 'fdcnt' => $fdcnt + count($del), 'fcnt' => $fcnt + count($del)];
                    $log = '  ' . sprintf(span_r, implode("\n  ", array_map(create_function('$v', 'return "$v - file deleted";'), $del)));
                }
            }
        }
    } else $ary += ['step' => 4, '' => "\n"] and $fcnt or $log = loger();
    set($ary + ['i_dir' => $i_dir, 'i_file' => $i_file, 'addid' => $addid, 'fid' => $fid, 'cid' => $cid]);
    # 2do: process of renamed files and dirs.
    break;
case 4:
    $files2 = str2ary($files2);
    $files3 = str2ary($files3);
    set([
        'step' => 5,
        'add'  => $add = select_dirs($add, '!in_array($d, $files3)'),
        'del'  => $del = select_dirs($del, '!in_array($d, $files2)'),
        'dacnt' => str2cnt($add, ' '),
        'ddcnt' => str2cnt($del, ' '),
    ]);
    $log = "3. Directories added:\n" . loger($add) . "\n4. Directories deleted:\n" . loger($del);
    break;
case 5:
    $sid && sql($sql_update); # clear marks
    require '_dev/main/diff.php';
    $err = 0;
    $area = @area();
    set([
        'step'   => 6,
        'tables2' => implode(' ', $tables2 = get_tables2($rows = filter_rows($area->inc_r, $area->exc_r))),
        'rows'   => implode(' ', $rows),
        'sqt'   => str_replace("\n", "\t", $sqt = tables_diff($log, $err, $tables = compare_tables($area->inc_t, $area->exc_t, $tables2, $sql))),
        'tables' => str_replace("\n", "\t", serialize($tables)),
        'tacnt' => $tacnt, 'tdcnt' => $tdcnt, 'tecnt' => $tecnt,
        'i_dir=i_file=mode' => 0, 'columns' => '', 'alt_errors' => $err,
    ]);
    $log = "5. Processing difference in tables structure:\n$log\n6. Processing rows:";
    # 2do: process of renamed tables.
    break;
case 6:
    require '_dev/main/diff.php';
    $rows = str2ary($rows);
    $columns = str2ary($columns);
    $tables = unserialize(str_replace("\t", "\n", $tables));
    if ($i_dir < count($rows)) {
        list ($table, $cn, $cp, $where) = explode('.', $rows[$i_dir], 4);
        $asr = (int)@$dis_records[$table];
        if (-1 === $asr) echo_json("-Error: all rows from table `$table` cannot be processed. Stop.", true);
        if ('?' === $cp) echo_json("-Error: table `$table` do not have auto_increment column. Stop.", true);
        isset($tables[$table]) and $sts = $tables[$table] or $mode = 2;
        if (
            0 === $mode and 0 !== $sts # table exists now
            and $r = sql("-select * from $table $where order by $cn limit $i_file, 1") # new row exists
        ) {
            $id = $r[$cp];
            if ($asr && $id > $asr) echo_json("-Error: rows > $asr from table `$table` cannot be processed. Stop.", true);
            $i_file++;
            $ary += ['rcnt' => ++$rcnt];
            $row_def = "$table.$id";
            $new = make_insert($r);
            if (1 !== $sts && eval(sqlf("^$tpl_select=0 and cmemo='$row_def'", 'tmemo, title>400 as bz, id'))) {
                # old row exists, structure identical or changed
                sql("update _dev_memory set cmemo='.$row_def' where id=$r_id"); # mark row!
                if ($r_bz) $r_tmemo = bzdecompress(base64_decode($r_tmemo));
                if ($dat = compare_rows($new, $r_tmemo)) {
                    $addid .= write_cb($rid, intelligent_update($dat), "u:table$table");
                    $log = "  $row_def - row changed";
                    $ary += ['recnt' => ++$recnt];
                } else $log = '.'; # 2 rows is equal
            } else { # new row added (may be in new table)
                $addid .= write_cb($rid, intelligent_insert(explode("\n", $new)), "u:table$table");
                $log = sprintf(span_g, "  $row_def - row added");
                $ary += ['racnt' => ++$racnt];
            }
        } elseif (1 === $mode) { # search for deleted rows
            $n = 1 + strlen("$table.");
            '' === $where or $where = strtr($where, ['where' => 'and (', $cn => "mid(cmemo,$n)"]) . ')';
            $tpl = "+$tpl_select=0 and %s union select 0 as id order by id desc limit %s, 1";
            if ($id = sql(sprintf($tpl, "mid(cmemo,$n) as id", "left(cmemo,$n-1)='$table.' $where", $i_file++))) {
                $addid .= write_cb($rid, "# SQL:  #\ndelete from $table where $cn=$id;", "u:table$table");
                $log = sprintf(span_r, "  $table.$id - row deleted");
                $ary += ['rdcnt' => ++$rdcnt];
            } else $mode = 2;
        } elseif (0 === $mode && !is_int($sts)) $ary += ['mode' => 1] and $i_file = 0;
        else $mode = 2;
        if (2 === $mode) $ary += ['mode' => 0, 'columns' => ''] and ++$i_dir and $i_file = 0;
    } else $ary += ['step' => 7] and $rcnt or $log = loger();
    set($ary + ['i_dir' => $i_dir, 'i_file' => $i_file, 'addid' => $addid, 'rid' => $rid]);
    break;
case 7:
    $sid && sql($sql_update); # clear marks
    if ($addid) {
        sql("update _dev_codebase set childs='$addid,' where id=$eid");
        write_cb($eid, '# RUN RECORDS: ' . list_imp($addid) . ' #');
    }
    $add === '' || write_cb($eid, "# CREATE DIRS:  #\n" . _opt($add));
    $del === '' || write_cb($eid, "# DELETE DIRS:  #\n" . _opt($del));
    $pos = strpos($memory, "\n#");
    $dfs = trim(substr($memory, 2 + $pos, strpos($memory, "\n", 1 + $pos) - 2 - $pos));
    $dfs === '' || write_cb($eid, "# DELETE FILES:  #\n" . _opt($dfs));
    $sqt === '' || write_cb($eid, "# SQL:  #\n" . str_replace("\t", "\n", $sqt));
 
    $total = $facnt + $tacnt + $racnt + $dacnt + $fdcnt + $tdcnt + $rdcnt + $ddcnt + $fecnt + $tecnt + $recnt;
    $ftrd = "A^$facnt/$tacnt/$racnt/$dacnt D^$fdcnt/$tdcnt/$rdcnt/$ddcnt E^$fecnt/$tecnt/$recnt/_ R^0/0/_/0"; # 2do: like in parser_cbr.php
    list ($records, $allsize) = sql("-select count(1), sum(length(code)) from _dev_codebase where id in ($eid$addid)");
    $head = "author: $u_sky_inet_login\nscript tested: no\nedited manualy: no";
    $head .= "\nftrd: $ftrd\nthis script: auto, $records records, $total objects, $allsize bytes";
    # 2do: auto-determine rollback, wind's rollback
    $head .= "\nreused code: ?\nrollback: yes\nrollback wind: yes\ntext files: " . implode(' ', $u_text_files); # 2do: collect minimal set
    '' === $u_inc_p or $head .= "\ninclude paths: $u_inc_p";
    '' === $u_exc_p or $head .= "\nexclude paths: $u_exc_p";
    '' === $u_inc_t or $head .= "\ninclude tables: $u_inc_t";
    '' === $u_exc_t or $head .= "\nexclude tables: $u_exc_t";
    '' === $u_inc_r or $head .= "\ninclude rows: $u_inc_r";
    '' === $u_exc_r or $head .= "\nexclude rows: $u_exc_r";
    if ($priorun) {
        $list = array_map(create_function('$v', 'return (int)substr($v, 1);'), str2ary($priorun));
        write_cb($eid, '# RUN RECORDS: ' . list_imp($list) . ' #');
    }
    write_cb($eid, "# HEAD:  #\n$head");
    $app = 'a' == $k_type ? "This is app `$k_name`" : "$code_types[$k_type] for `$u_my_app`";
    $from = $sid ? "Snapshot <a href=\"?utility=snapshots&id=$sid\">ID=$sid</a> from $stime" : 'Scratch';
    if ($alt_errors) $from .= sprintf(span_r, "<br>\nWarning! $alt_errors errors possible when ALTER TABLE, please check manualy!");
    write_cb($eid, "# DESC: en #\n$app\nCreated from $from");
    sql("update _dev_codebase set code=concat(code,'\n\n# END:  #') where id=$eid");
    $start = round(microtime(true) - $start, 3);
    set(['ftrd' => $ftrd, 'cnt' => $records, 'size' => $allsize, 'objects' => $total, 'step' => 8]);
    $ftrd = "FTRD: $ftrd " . '<span class="pop" id="pop_ftrd">?</span>';
    $log = "7. Time left: <u>$start seconds</u>. Enter point <a href=\"?cb_show=$eid\">ID=$eid</a> created.\n   $ftrd";
    break;
case 8:
    $build_id = sql("+select ifnull(max(id)+1,501) from _dev_memory where id>500 and id<1000");
    if ($build_id == 1000) echo_json('-Internal error: maximum Builds reached!', true);
    # delete Builds
    if ($del_builds) sql("delete from _dev_memory where id in ($del_builds)");
    # write Package
    $package_id = sqlf("insert into _dev_packages %s", [
        'name' => "'$k_name'",
        'lang' => "'$k_lang'",
        'rubric_id' => $k_rubric,
        'start_id' => $eid,
        'status' => "'00$k_type 0 0 00000 t 01'",
        'dt' => 'now()',
        'tmemo' => escape(set([
            'cnt' => (int)$cnt,
            'size' => (int)$size,
            'ftrd' => $ftrd,
            'objects' => (int)$objects,
            'sky_id' => 0,
            'author' => $u_sky_inet_login,
            'app' => $u_my_app,
            'priorun' => $priorun,
            'depends' => $depends,
            'included' => $included,
            '_desc' => '',
        ], 0, 0)),
    ]);
    sql("update _dev_codebase set package_id=$package_id where id>=$eid");
    # write Build
    sqlf("insert into _dev_memory %s", [
        'id' => $build_id,
        'code' => $eid, # start_id
        'imemo' => $package_id,
        'cmemo' => escape(ver(0.001, $k_name)), # name.ver
        'tmemo' => escape(set([
            'ftrd' => $ftrd,
            'can_rollback' => 1,
            'sky_id' => 0,
            'run_changed' => 0,
            'priorun' => $priorun,
        ], [], 0)),
        'dt' => 'now()',
    ]);
    set('d_id_script', (int)$build_id, 2); # memo last build_id
    $log = "+8. Package `$k_name`, Build written.\n9. Done.";
    break;
 
endswitch;
 
echo_json($log);
 
 
 
else: # HTML PAGE
 
$TOP = "<b><u>Make scripts + Package</u></b> &lt; from " . ($WVAL ? "<a href=\"?utility=snapshots&id=$WVAL\">Snapshot ID=$WVAL</a>" : 'Scratch');
eval(cell(250));
echo '<form method="post" id="f1">';
eval($WVAL ? cell("id>1000 and code=-1 and imemo=$WVAL", 'm') : cell(88));
is_array($u_text_files) or $u_text_files = str2ary($u_text_files);
is_array($u_svn_skips) or $u_svn_skips = str2ary($u_svn_skips);
$auname = sprintf("u{$u_nupd}_%s." . ('.sky.' == substr($u_my_app, -5) ? substr($u_my_app, 0, -5) : $u_my_app), strtolower($u_sky_inet_login));
 
require '_dev/main/area.php' ?>
<p><fieldset><legend>Package settings</legend>
Package name: <input name="title" id="title" value="" />
<?=pad()?>Type: <select name="ptype" onchange="prename(this)"><?=option($WVAL ? 'u' : 'a', $code_types)?></select><br>
<label><input type="checkbox" name="hw" checked /> Human programming work done</label><br>
<label><input type="checkbox" name="wr" /> try to create Wind-ready script</label>
</fieldset><br>
<input type="button" value="Do make - F9" onclick="key_F9()" />
</form>
<pre id="log"></pre>
 
<script type="text/javascript">
var f1 = $('f1'), udname = '<?=$auname?>',
    myapp = '<?=$u_my_app?>';
function prename(el) {
    if (typeof el == 'object') el = el.value;
    switch (el) {
        case 'a': $('title').value = myapp; break;
        case 'm': $('title').value = 'm' + udname.substr(1); break;
        case 'u': $('title').value = udname; break;
        case 't': $('title').value = 't' + udname.substr(1); break;
        case 's': $('title').value = 's' + udname.substr(1); break;
    }
}
prename('u');
var r = '<?=$WVAL?"Snapshot ID=$WVAL":'Scratch'?></b><br>You can use Package to submit your work on <?=SKY?> for sharing.';
r += '<br>You must edit some data before sending package to remote server.';
mtop('This will create DEV.SKY. parser scripts (plus Package) for reaching current project state <b>from ' + r);
function key_F9() {
    if (f1.inc_p.value.match(/\*/)) return mtop('`*` chars not allowed in `include paths` area', red);
    var v = '&t=' + f1.ptype.value + '&w=' + (f1.hw.checked ? 1 : 0) + '&n=' + e$(f1.title.value) + qs_area();
    cycle('&ini=<?=$WVAL?>' + v, 'Creating DEV.SKY. script.');
}
</script>
<?php
 
endif;    # '&r=' + f1.rubric.value + '&l=' + f1.lang.value
#Rubric: <select name="rubric"><?=option($u_my_rubric, $dev_rubrics)</select><?=pad()
#Language: <select name="lang"><option value="__">--not defined--<?=option('__', $all_lang_list)</select>