filestash/public/assets/pages/filespage/model_files.js

import rxjs from "../../lib/rx.js";
import ajax from "../../lib/ajax.js";

// export function ls() {
//     return rxjs.from(new Error("missing cache")).pipe(
//         rxjs.catchError(() => rxjs.of({ files: null })),
//         rxjs.mergeMap(({ files: filesInCache }) => ajax({
//             url: `/api/files/ls?path=${path}`,
//             responseType: "json"
//         }).pipe(
//             rxjs.map(({ responseJSON }) => responseJSON),
//             rxjs.filter(({ filesInRemote }) => {
//                 if (!Array.isArray(filesInCache)) return true;
//                 if (filesInCache.length != filesInRemote.length) return true;
//                 for (let i=0; i<filesInCache.length; i++) {
//                     if (filesInCache[i].name !== filesInRemote[i].name) return true;
//                 }
//                 return false;
//             }),
//         )),
//     )
// }

export function search(term) {
    const path = location.pathname.replace(new RegExp("^/files/"), "/");
    return ajax({
        url: `/api/files/search?path=${path}&q=${term}`,
        responseType: "json"
    }).pipe(
        rxjs.map(({ responseJSON }) => ({files: responseJSON.results })),
    );
}

export function ls(path) {
    return rxjs.merge(
        rxjs.of(null),
        rxjs.fromEvent(window, "keydown").pipe( // "r" shorcut
            rxjs.filter((e) => e.keyCode === 82 && document.activeElement.tagName !== "INPUT"),
        )
    ).pipe(rxjs.mergeMap(() => ajax({
        url: `/api/files/ls?path=${path}`,
        responseType: "json"
    }).pipe(rxjs.map(({ responseJSON }) => ({
        files: responseJSON.results.sort(sortByDefault),
        path,
    })))));
}

const sortByDefault = (fileA, fileB) => {
    if (fileA.type !== fileB.type) {
        if (fileA.type === "file") return +1;
        return -1;
    }
    // if (fileA.name < fileB.name) {
    //     return -1
    // }
    return 0;
};