tesses-cms/Tesses.CMS.Providers.Dapper/Class1.cs

359 lines
12 KiB
C#

using System;
using System.Collections.Generic;
using Tesses.CMS;
using Dapper;
using System.Data.Common;
using System.Linq;
using Newtonsoft.Json;
namespace Tesses.CMS.Providers
{
public class MysqlDapperContentProvider : IContentProvider
{
DbConnection con;
public MysqlDapperContentProvider(DbConnection connection)
{
this.con = connection;
con.Execute("CREATE TABLE IF NOT EXISTS Users (Id bigint NOT NULL PRIMARY KEY AUTOINCREMENT,AboutMe text,AccountsToMail text,Email text,IsAdmin bool,IsInvited bool,IsVerified bool,PasswordHash text,ProperName text,Salt text,Username text,Webhooks text);");
con.Execute("CREATE TABLE IF NOT EXISTS Sessions (Id bigint NOT NULL PRIMARY KEY AUTOINCREMENT,Session text,Account bigint);");
con.Execute("CREATE TABLE IF NOT EXISTS VerificationCodes (Id bigint NOT NULL PRIMARY KEY AUTOINCREMENT,Session text,Account bigint,Expires bigint);");
con.Execute("CREATE TABLE IF NOT EXISTS Movies (Id bigint NOT NULL PRIMARY KEY AUTOINCREMENT,UserId bigint,CreationTime bigint,LastUpdated bigint,Description text,Name text,ProperName text);");
}
public void ChangeSession(string session, long account)
{
con.Execute("UPDATE Sessions set Account = @account WHERE Session = @session;",new{session,account});
}
public bool ContainsSession(string cookie)
{
return con.QueryFirstOrDefault("SELECT * FROM Sessions WHERE Session = @cookie;",new{cookie})!=null;
}
public bool ContainsVerificationCode(string code)
{
var res=con.QueryFirstOrDefault("SELECT * FROM VerificationCodes WHERE Session = @code;",new{code});
if(res != null)
{
long expires = res.Expires;
if(DateTimeOffset.Now>= DateTimeOffset.FromUnixTimeSeconds(expires))
{
con.Execute("DELETE FROM VerificationCodes WHERE Session = @code;",new{code});
return false;
}
return true;
}
return false;
}
public Episode CreateEpisode(string user, string show, int season, int episode, string episodename, string properName, string description)
{
throw new NotImplementedException();
}
public Movie CreateMovie(string user, string movie, string properName, string description)
{
var userId=GetUserAccount(user).Id;
Movie movie1=new Movie();
movie1.UserId = userId;
movie1.Name = movie;
movie1.ProperName=properName;
movie1.Description=description;
con.Execute("INSERT INTO Movies(movie) values (@movie);",new{movie=new DapperMovie(movie1)});
return GetMovie(user,movie);
}
public Season CreateSeason(string user, string show, int season, string properName, string description)
{
throw new NotImplementedException();
}
public void CreateSession(string session, long account)
{
con.Execute("INSERT INTO Sessions(Session,Account) values (@session,@account);",new{session,account});
}
public Show CreateShow(string user, string show, string properName, string description)
{
throw new NotImplementedException();
}
public void CreateUser(CMSConfiguration configuration, string user, string properName, string email, string password)
{
bool first=con.QueryFirstOrDefault<DapperUserAccount>("SELECT * FROM Users LIMIT 0, 1;") == null;
UserAccount account=new UserAccount();
account.IsAdmin = first;
account.IsVerified = first;
account.Email =email;
account.ProperName = properName;
account.Username = user;
account.NewSalt();
account.PasswordHash = account.GetPasswordHash(password);
DapperUserAccount account1=new DapperUserAccount(account);
con.Execute("INSERT INTO Users(user) values (@user);",new{user=account1});
}
public void CreateVerificationCode(string code, long account)
{
long expires=DateTimeOffset.Now.AddDays(1).ToUnixTimeSeconds();
con.Execute("INSERT INTO VerificationCodes(Session,Account,Expires) values (@code,@account,@expires);",new{code,account,expires});
}
public void DeleteSession(string session)
{
con.Execute("DELETE FROM Sessions WHERE Session = @session;",new{session});
}
public void DeleteVerificationCode(string code)
{
con.Execute("DELETE FROM VerificationCodes WHERE Session = @code;",new{code});
}
public int EpisodeCount(string user, string show, int season)
{
throw new NotImplementedException();
}
public Episode GetEpisode(string user, string show, int season, int episode)
{
throw new NotImplementedException();
}
public UserAccount GetFirstUser()
{
return con.QueryFirstOrDefault<DapperUserAccount>("SELECT * FROM Users LIMIT 0, 1;")?.Account;
}
public Movie GetMovie(string user, string movie)
{
long? id =GetUserAccount(user)?.Id;
if(!id.HasValue) return null;
return con.QueryFirstOrDefault<DapperMovie>("SELECT * FROM Users WHERE UserId=@id; AND Name=@movie",new{movie,id})?.MovieObject;
}
public IEnumerable<Movie> GetMovies(string user)
{
long? id =GetUserAccount(user)?.Id;
if(!id.HasValue) yield break;
foreach(var item in GetMovies(id.Value))
{
yield return item;
}
}
public IEnumerable<Movie> GetMovies(long user)
{
foreach(var item in con.Query<DapperMovie>("SELECT * FROM Movies;"))
{
yield return item.MovieObject;
}
}
public Season GetSeason(string user, string show, int season)
{
throw new NotImplementedException();
}
public long? GetSession(string session)
{
return con.QueryFirstOrDefault("SELECT * FROM Sessions WHERE Session = @session;",new{session})?.Id;
}
public Show GetShow(string user, string show)
{
throw new NotImplementedException();
}
public IEnumerable<Show> GetShows(string user)
{
throw new NotImplementedException();
}
public UserAccount GetUserAccount(string user)
{
return con.QueryFirstOrDefault<DapperUserAccount>("SELECT * FROM Users WHERE Username=@user;",new{user})?.Account;
}
public UserAccount GetUserById(long account)
{
return con.QueryFirstOrDefault<DapperUserAccount>("SELECT * FROM Users WHERE Id=@id;",new{id=account})?.Account;
}
public IEnumerable<UserAccount> GetUsers()
{
foreach(var user in con.Query<DapperUserAccount>("SELECT * FROM Users;"))
{
yield return user.Account;
}
}
public long? GetVerificationAccount(string code)
{
var res=con.QueryFirstOrDefault("SELECT * FROM VerificationCodes WHERE Session = @code;",new{code});
if(res != null)
{
long expires = res.Expires;
if(DateTimeOffset.Now>= DateTimeOffset.FromUnixTimeSeconds(expires))
{
con.Execute("DELETE FROM VerificationCodes WHERE Session = @code;",new{code});
return null;
}
return res.Account;
}
return null;
}
public int SeasonCount(string user, string show)
{
throw new NotImplementedException();
}
public void UpdateEpisode(Episode episode)
{
throw new NotImplementedException();
}
public void UpdateMovie(Movie movie)
{
DapperMovie dapperMovie=new DapperMovie(movie);
con.Execute("UPDATE Users set movie = @movie WHERE Id = @id;",new{movie=dapperMovie,id=movie.Id});
}
public void UpdateSeason(Season season)
{
throw new NotImplementedException();
}
public void UpdateShow(Show show)
{
throw new NotImplementedException();
}
public void UpdateUser(UserAccount account)
{
DapperUserAccount account1=new DapperUserAccount(account);
con.Execute("UPDATE Users set user = @user WHERE Id = @id;",new{user=account1,id=account1.Id});
}
}
internal class DapperMovie
{
public long Id {get;set;}
public long UserId {get;set;}
public long CreationTime {get;set;}
public long LastUpdated {get;set;}
public string Description {get;set;}
public string Name {get;set;}
public string ProperName {get;set;}
public Movie MovieObject {
get{
return new Movie(){
UserId = UserId,
CreationTime=DateTimeOffset.FromUnixTimeSeconds(CreationTime).DateTime,
LastUpdated=DateTimeOffset.FromUnixTimeSeconds(LastUpdated).DateTime,
Description=Description,
Id=Id,
Name=Name,
ProperName=ProperName
};
}
set{
UserId=value.UserId;
CreationTime=new DateTimeOffset(value.CreationTime).ToUnixTimeSeconds();
LastUpdated=new DateTimeOffset(value.LastUpdated).ToUnixTimeSeconds();
Description=value.Description;
Id=value.Id;
Name=value.Name;
ProperName=value.ProperName;
}
}
public DapperMovie(Movie movie1)
{
MovieObject = movie1;
}
public DapperMovie()
{
}
}
internal class DapperUserAccount
{
public DapperUserAccount()
{
}
public DapperUserAccount(UserAccount account)
{
Account =account;
}
public long Id {get;set;}
public string AboutMe {get;set;}
public string AccountsToMail { get; set; }
public string Email { get; set; }
public bool IsAdmin {get;set;}
public bool IsInvited {get;set;}
public bool IsVerified {get;set;}
public string PasswordHash {get;set;}
public string ProperName {get;set;}
public string Salt {get;set;}
public string Username {get;set;}
public string Webhooks {get;set;}
public UserAccount Account {
get {
return new UserAccount(){
Id = Id,
AboutMe = AboutMe,
AccountsToMail=JsonConvert.DeserializeObject<List<MailEntry>>(AccountsToMail),
Email=Email,
IsAdmin=IsAdmin,
IsInvited=IsInvited,
IsVerified=IsVerified,
PasswordHash=PasswordHash,
ProperName=ProperName,
Salt=Salt,
Username=Username,
Webhooks = JsonConvert.DeserializeObject<List<WebHook>>(Webhooks)
};
}
set{
Id = value.Id;
AboutMe = value.AboutMe;
AccountsToMail = JsonConvert.SerializeObject(value.AccountsToMail);
Email=value.Email;
IsAdmin = value.IsAdmin;
IsInvited = value.IsInvited;
IsVerified = value.IsVerified;
PasswordHash = value.PasswordHash;
ProperName = value.ProperName;
Salt = value.Salt;
Username = value.Username;
Webhooks = JsonConvert.SerializeObject(value.Webhooks);
}
}
}
}