X-Git-Url: https://git.mdrn.pl/ReadingsJQM.git/blobdiff_plain/c956fba7332f45e9abab07b2b8ac417b0f6514c8..refs/heads/readings:/js/app/Catalogue.js

diff --git a/js/app/Catalogue.js b/js/app/Catalogue.js
new file mode 100644
index 0000000..a1999bf
--- /dev/null
+++ b/js/app/Catalogue.js
@@ -0,0 +1,143 @@
+(function() {
+
+  Readings.Catalogue = (function() {
+
+    function Catalogue() {}
+
+    Catalogue.prototype.open = function() {
+      var version;
+      version = Readings.config.get('db_version');
+      console.log("opening db ver " + version);
+      this.db = openDatabase('catalogue', version, 'Catalogue', 65535, this.init);
+      return this;
+    };
+
+    Catalogue.prototype.init = function(db) {
+      var unneded_stmts,
+        _this = this;
+      unneded_stmts = function(stmt, idx) {
+        return stmt.indexOf("PRAGMA") === 0 || stmt.indexOf("BEGIN TRANSACTION") === 0 || stmt.indexOf("COMMIT") === 0 || /^\s*$/.exec(stmt);
+      };
+      if (!(db != null)) db = this.db;
+      console.log("initializing DB");
+      db.changeVersion("", Readings.config.get('db_version'));
+      return $.ajax(Readings.config.get('initdburl'), {
+        type: "GET",
+        dataType: 'text',
+        success: function(sql) {
+          var create;
+          sql = sql.split(/;\n/);
+          sql = $.grep(sql, unneded_stmts, true);
+          create = function(tx) {
+            var stmt, _i, _len, _results;
+            _results = [];
+            for (_i = 0, _len = sql.length; _i < _len; _i++) {
+              stmt = sql[_i];
+              _results.push(tx.executeSql(stmt, [], function(tx, rs) {
+                return true;
+              }, function(tx, err) {
+                console.error("error for " + stmt);
+                return console.error(err);
+              }));
+            }
+            return _results;
+          };
+          return db.transaction(create);
+        },
+        error: function() {
+          return console.error("can't get initial sql");
+        }
+      });
+    };
+
+    Catalogue.prototype.wrap_error = function(error_cb) {
+      return function(tx, error) {
+        window.last_error = error;
+        alert("SQL ERROR: " + error.message);
+        if (error_cb) {
+          return error_cb(error);
+        } else {
+          throw error;
+        }
+      };
+    };
+
+    Catalogue.prototype.map_rs = function(rs, mapper) {
+      var i, objs, _ref;
+      objs = [];
+      for (i = 0, _ref = rs.rows.length; 0 <= _ref ? i < _ref : i > _ref; 0 <= _ref ? i++ : i--) {
+        objs.push(mapper(rs.rows.item(i)));
+      }
+      return objs;
+    };
+
+    Catalogue.prototype.withCategory = function(category, callback, error) {
+      var rs_to_tags,
+        _this = this;
+      rs_to_tags = function(tx, data) {
+        var i, tags, _ref;
+        tags = [];
+        for (i = 0, _ref = data.rows.length; 0 <= _ref ? i < _ref : i > _ref; 0 <= _ref ? i++ : i--) {
+          tags.push(new Readings.Tag(data.rows.item(i)));
+        }
+        return callback(tags);
+      };
+      return this.db.readTransaction(function(tx) {
+        return tx.executeSql("SELECT * FROM tag WHERE category=? ORDER BY sort_key", [category], rs_to_tags, _this.wrap_error(error));
+      });
+    };
+
+    Catalogue.prototype.withTag = function(tag_id, cb) {
+      var _this = this;
+      return this.db.readTransaction(function(tx) {
+        return tx.executeSql("SELECT * FROM tag WHERE id=?", [tag_id], function(tx, rs) {
+          var tag;
+          if (rs.rows.length > 0) {
+            tag = new Readings.Tag(rs.rows.item(0));
+            return cb(tag);
+          } else {
+            return alert("No tag id " + tag_id);
+          }
+        }, _this.wrap_error());
+      });
+    };
+
+    Catalogue.prototype.withBooks = function(tag, cb) {
+      var _this = this;
+      return this.db.readTransaction(function(tx) {
+        console.log("books in tag: " + tag.books);
+        return tx.executeSql("SELECT * FROM book WHERE id IN (" + tag.books + ") ORDER BY sort_key", [], (function(tx, rs) {
+          return cb(_this.map_rs(rs, function(rec) {
+            return new Readings.Book(rec);
+          }));
+        }), _this.wrap_error());
+      });
+    };
+
+    Catalogue.prototype.fetchBook = function(book_id, fetch_contents, cb) {
+      var _this = this;
+      if (!(typeof book_id === "number" || /^[0-9]+$/.exec(book_id))) {
+        throw Error("book_id = '" + book_id + "' is not a number");
+      }
+      return this.db.readTransaction(function(tx) {
+        return tx.executeSql("SELECT * FROM book WHERE id=?", [book_id], function(tx, rs) {
+          var book;
+          if (rs.rows.length > 0) {
+            book = new Readings.Book(rs.rows.item(0));
+            if (fetch_contents && !book.is_local()) {
+              return book.fetch(function(book) {
+                return cb(book);
+              });
+            } else {
+              return cb(book);
+            }
+          }
+        });
+      });
+    };
+
+    return Catalogue;
+
+  })();
+
+}).call(this);