<?php

require_once 'db.function.php';

//$bedfile_id = 1;
function load_bed($bedfile_id, $filepath) {
    $fields = array('bedfile_id', 'chrom', 'chromstart', 'chromend', 'name', 'score', 'strand', 'thickstart', 'thickend', 'itemrgb', 'blockcount', 'blocksizes', 'blockstarts');
    // open the file
    //$fp = fopen($_FILES['file']['tmp_name'], "r");
    $fp = fopen($filepath, "r");
    // check if file has a header line
    $header = fgets($fp);
    if(stripos($header, 'chr') === 0) {
        $r = explode("\t", trim($header)); //since str_getcsv is only available php 5.3+, we assume no special CSV in file
    } else {
        $r = fgetcsv($fp, 0, "\t");
    }
    // determine what columns are present in the file
    array_unshift($r, $bedfile_id);
    if(count($r) < 4 || count($r) > count($fields)) {
        return "Invalid BED file--too many or too few columns. Saved as raw.";
    } else if(strpos($r[1], "chr") !== 0) {
        return "Invalid BED file--row doesn't begin with 'chr'. Saved as raw.";
    }
    $f = array_slice($fields, 0, count($r));
    $myfields = join(',', $f);
    $qmarks = join(',', array_fill(0, count($f), '?'));
    // insert each row into db
    $db = getDB();
    $sth = $db->prepare("insert into summarybed ($myfields) values ($qmarks)");
    $stat = $db->execute($sth, $r);
    if(PEAR::isError($stat)) {
        file_put_contents("/tmp/dasrload.log", "Date ".date('YmdHis')." ".print_r($stat, true));
        //return $stat->getUserInfo();
        return $stat->getMessage();
    }
    $i = 1;
    while($r = fgetcsv($fp, 0, "\t")) {
        // trim the row:
        for($j = count($r) - 1; $r[$j] === ''; $j--) {
            array_pop($r);
        }
        $i++;
        array_unshift($r, $bedfile_id);
        $stat = $db->execute($sth, $r);
        if(PEAR::isError($stat)) {
            file_put_contents("/tmp/dasrload.log", "Date ".date('YmdHis')."file line $i...\n".print_r($r, true) . print_r($stat, true));
            //return $stat->getUserInfo();
            return $stat->getMessage();
        }
    }
    $db->commit();
}

?>