Compare commits

...

2 Commits

Author SHA1 Message Date
843f779010 changes, ok? 2022-12-24 03:43:09 +01:00
78fd88654d update gitignore 2022-12-24 03:42:51 +01:00
6 changed files with 144 additions and 62 deletions

4
.gitignore vendored
View File

@ -1,4 +1,6 @@
api2/ api2/
**/build/ **/build/
out.js out.js
api/node_modules/ api/node_modules/
**/*.sqlite
**/.vscode/

View File

@ -4,27 +4,35 @@ import tink.http.Response;
import tink.web.routing.*; import tink.web.routing.*;
import tink.sql.drivers.Sqlite; import tink.sql.drivers.Sqlite;
import db.Db; import db.Db;
import haxe.Json;
import model.MUser; import model.MUser;
import controller.IDGen; import controller.IDGen;
import controller.User; import controller.User;
import db.Db.Database as Db; typedef T_project = {
name : String,
description : String,
url : String
}
typedef T_projects = {
version : Int,
projects : Array<T_project>
}
class Server { class Server {
@await public static var db:Db;
static function main() { static function main() {
var container = new NodeContainer(8080); var container = new NodeContainer(8080);
//var container = PhpContainer.inst; //use PhpContainer instead of NodeContainer when targeting PHP //var container = PhpContainer.inst; //use PhpContainer instead of NodeContainer when targeting PHP
var router = new Router<Root>(new Root()); var router = new Router<Root>(new Root());
Db.createTables();
container.run(function(req) { container.run(function(req) {
return router.route(Context.ofRequest(req)) return router.route(Context.ofRequest(req))
.recover(OutgoingResponse.reportError); .recover(OutgoingResponse.reportError);
}); });
} }
public static var db:
} }
class Root { class Root {
@ -65,10 +73,10 @@ class Root {
public function user() public function user()
return new User(); return new User();
// @:sub('/projects') @:sub('/projects')
// @:produces('application/json') @:produces('application/json')
// public function projects() public function projects()
// return new Projects(); return new Projects();
@:get('/hello') @:get('/hello')
@:produces('application/json') @:produces('application/json')
@ -84,3 +92,29 @@ class Root {
return new IDGen(); return new IDGen();
} }
class Projects {
public function new() {}
public var path:String = "./res/json/projects.json";
@:get('/')
@:produces('application/json')
public function projects(){
var json:String = Utils.getJson(path);
return json;
}
@:get('/project/by_name/$name')
@:produces('application/json')
public function project(name:String){
var json:String = Utils.getJson(path);
var _projects:T_projects = Json.parse(json);
json = "{}";
for(_project in _projects.projects){
if(_project.name == name){
json = tink.Json.stringify(_project);
}
}
return json;
}
}

View File

@ -12,11 +12,9 @@ using tink.CoreApi;
class User{ class User{
private static var driver = new tink.sql.drivers.Sqlite();
@await private static var database:Db = new Db_DrivebyCool('db.sqlite', driver); @await private static var db:Db = new Db('db.sqlite', driver);
public function new() {} public function new() {}
@:get('/') @:get('/')
@:produces('text/plain') @:produces('text/plain')
@ -63,7 +61,7 @@ class User{
@:get('/registerDummyUser') @:get('/registerDummyUser')
@:produces('application/json') @:produces('application/json')
public function registerdummyuser(){ public function registerdummyuser(){
//@await var db = new Db('daba2', driver); //@await var db = new Db('db.sqlite', driver);
// var failed:tink.core.Next<tink.sql.Id<model.MUser>> = null // var failed:tink.core.Next<tink.sql.Id<model.MUser>> = null
return createUserTable().next(function(_){ return createUserTable().next(function(_){
return db.MUser.insertOne({ return db.MUser.insertOne({
@ -118,9 +116,7 @@ class User{
@:get('/fetchalice') @:get('/fetchalice')
@:produces('application/json') @:produces('application/json')
public function fetchalice(){ public function fetchalice(){
var driver = new tink.sql.drivers.Sqlite();
return db.MUser.select({name: MUser.name, email: MUser.email}).where(MUser.email == 'alice@example.com').first().next(function(row) { return db.MUser.select({name: MUser.name, email: MUser.email}).where(MUser.email == 'alice@example.com').first().next(function(row) {
return row; return row;
}); });

View File

@ -1,29 +1,84 @@
package db; package db;
// import tink.sql.drivers.Sqlite; import tink.sql.drivers.Sqlite;
//import tink.sql.Database; import tink.sql.Database;
import tink.sql.Types; import tink.sql.Types;
import model.MUser; import model.MUser;
import model.services.DrivebyCool; import model.services.DrivebyCool;
import tink.CoreApi;
@:tables(MUser)
@:tables(MProject)
@:tables(MUser)
@:tables(MProject)
// Post related Tables // Post related Tables
@:tables(MPost) @:tables(MPost)
@:tables(MTag) @:tables(MTag)
@:tables(MPostTag) @:tables(MTaggedPost)
interface DbDef_DrivebyCool extends tink.sql.DatabaseDefinition { interface DbDef_DrivebyCool extends tink.sql.DatabaseDefinition {
//@:procedure var func:Int->{x:Int, point:tink.s2d.Point}; //@:procedure var func:Int->{x:Int, point:tink.s2d.Point};
@:table('user') var UserTbl:MUser; @:table('user') var UserTbl:MUser;
// @:table('project') var ProjectTbl:DrivebyCool.MProject; // @:table('project') var ProjectTbl:DrivebyCool.MProject;
} }
class Database extends tink.sql.Database<Def> {
class Db extends tink.sql.Database<DbDef_DrivebyCool> {
public function new(__name:String,driver:tink.sql.Driver){ public function new(__name:String,driver:tink.sql.Driver){
super(__name, driver); super(__name, driver);
} }
private static var driver = new tink.sql.drivers.Sqlite();
@async private static var db:Db = new Db('db.sqlite', driver);
@async public static function getDb()
{
return @await db;
}
public static function createTables():Void public static function createTables():Void
{ {
var db = Db.getDb();
@async var execute = function(){
return db.MUser.create(true).next(function(_){
trace("aids");
return db.MProject.create(true);
}).next(function(_){
trace("aids");
return db.MPost.create(true);
}).next(function(_){
trace("aids");
return db.MTag.create(true);
}).next(function(_){
trace("aids");
return db.MTaggedPost.create(true);
});
}
@await execute().next(function(_){
trace(_);
return _;
}).handle(function(_){
trace(_);
});
// trace(two());
// @async var yeet = db.next(function(_db){
// return db.MUser.create();
// });
// yeet.next(function(_){
// trace("kanker");
// var test = @await db;
// return test.MProject.create(true);
// });
// .next(function(_){
// trace("kanker");
// return db.MPost.create(true);
// }).next(function(_){
// return db.MTag.create(true);
// }).next(function(_){
// return db.MTaggedPost.create(true);
// }).next(function(_){
// trace(_);
// });
// @await db.MProject.create(true);
// @await db.MPost.create(true);
// @await db.MTag.create(true);
// @await db.MTaggedPost.create(true);
} }
} }

View File

@ -6,6 +6,6 @@ import model.MService;
typedef MUser = { typedef MUser = {
@:autoIncrement @:primary public var id(default, null):Id<MUser>; @:autoIncrement @:primary public var id(default, null):Id<MUser>;
public var name:VarChar<50>; public var name:VarChar<50>;
public var email:VarChar<50>; public var email:VarChar<256>;
public var password:VarChar<50>; public var password:VarChar<256>;
} }

View File

@ -6,55 +6,50 @@ import model.MSubscription;
/* /*
* Project related models * Project related models
*/ */
// Defines a Project to be listed on the projects page //Defines a Project to be listed on the projects page
typedef MProject = { typedef MProject = {
@:autoIncrement @:primary public var id(default, null):Id<MProject>; @:autoIncrement @:primary public var id(default, null):Id<MProject>;
// Properties // Properties
public var name:VarChar<50>; public var name:VarChar<50>;
public var owner:Id<MUser>; public var owner:Id<MUser>;
public var description:VarChar<1024>; public var description:VarChar<1024>;
} }
// Defines a relationship between a Project and a User. The User will be added as a member of the project and can author blogposts // Defines a relationship between a Project and a User. The User will be added as a member of the project and can author blogposts
typedef MMembership = { typedef MMembership = {
@:autoIncrement @:primary public var id(default, null):Id<MMembership>; @:autoIncrement @:primary public var id(default, null):Id<MMembership>;
// relationships // relationships
public var project:Id<MProject>; public var project:Id<MProject>;
public var user:Id<MUser>; public var user:Id<MUser>;
} }
/*
* Defines a Post // Defines a Post
*/
typedef MPost = { typedef MPost = {
@:autoIncrement @:primary public var id(default, null):Id<MPost>; @:autoIncrement @:primary public var id(default, null):Id<MPost>;
// Relationships // Relationships
public var project:Id<MProject>; public var project:Id<MProject>;
public var owner:Id<MUser>; public var owner:Id<MUser>;
// Properties // Properties
public var title:VarChar<1024>; public var title:VarChar<1024>;
public var description:Text; public var description:Text;
public var content:Text; public var content:Text;
} }
// // Defines a tag that can be added to any post.
// Defines a tag that can be added to any post.
//
typedef MTag = { typedef MTag = {
@:autoIncrement @:primary public var id(default, null):Id<MTag>; @:autoIncrement @:primary public var id(default, null):Id<MTag>;
public var title:VarChar<32>; public var title:VarChar<32>;
} }
// // Defines a relationship between a tag and a post.
// Defines a relationship between a tag and a post.
//
typedef MTaggedPost = { typedef MTaggedPost = {
@:autoIncrement @:primary public var id(default, null):Id<MTaggedPost>; @:autoIncrement @:primary public var id(default, null):Id<MTaggedPost>;
public var post:Id<MPost>; public var post:Id<MPost>;
public var tag:Id<MTag>; public var tag:Id<MTag>;
} }