Selfhosting

src/Application/Managers/BookLocalStorageManager.cs

@@ -0,0 +1,156 @@
+using Application.Common.Exceptions;
+using Application.Interfaces.Managers;
+using Microsoft.AspNetCore.WebUtilities;
+using Microsoft.Net.Http.Headers;
+
+namespace Application.Managers;
+
+public class BookLocalStorageManager : IBookBlobStorageManager
+{
+ private readonly string _bookCoverPrefix = "cover_";
+ private string dataDir;
+ private string booksDir;
+ private string coversDir;
+ private string baseDir;
+
+ public BookLocalStorageManager()
+ {
+ baseDir=System.Environment.GetFolderPath(System.Environment.SpecialFolder.Personal);
+ dataDir= baseDir+"/librum_srorage";
+ booksDir= dataDir + "/books";
+ coversDir=booksDir + "/covers";
+ // create folders
+ if(! System.IO.Directory.Exists(dataDir)) System.IO.Directory.CreateDirectory(dataDir);
+ if(! System.IO.Directory.Exists(booksDir)) System.IO.Directory.CreateDirectory(booksDir);
+ if(! System.IO.Directory.Exists(coversDir)) System.IO.Directory.CreateDirectory(coversDir);
+ Console.WriteLine ("Current directory is "+ dataDir);
+ }
+
+ public Task<Stream> DownloadBookBlob(Guid guid)
+ {
+ var filename=booksDir+"/"+guid;
+ if (!System.IO.File.Exists(filename)){
+ throw new CommonErrorException(400,"file not exists "+filename ,0);
+ }
+ return Task.FromResult<Stream>(File.OpenRead(filename)); 
+ }
+
+ public async Task UploadBookBlob(Guid guid, MultipartReader reader)
+ {
+ //if already exists
+ var filename=booksDir+"/"+guid;
+ if ( System.IO.File.Exists(filename)){
+ throw new CommonErrorException(400,"file already exists "+filename ,0);
+ }
+ System.IO.Stream dest;
+ try {
+ dest = System.IO.File.Create (filename);
+ }
+ catch (Exception e)
+ {
+ throw new CommonErrorException(400, "Can't create file", 0);
+ }
+
+
+ var section = await reader.ReadNextSectionAsync();
+ while (section != null)
+ {
+ var hasContentDispositionHeader =
+ ContentDispositionHeaderValue.TryParse(
+ section.ContentDisposition,
+ out var contentDisposition);
+
+ if (!hasContentDispositionHeader)
+ continue;
+
+ if (!HasFileContentDisposition(contentDisposition))
+ {
+ var message = "Missing content disposition header";
+ throw new CommonErrorException(400, message, 0);
+ }
+
+ await section.Body.CopyToAsync(dest);
+
+ section = await reader.ReadNextSectionAsync();
+ }
+ dest.Dispose();
+ System.IO.File.SetUnixFileMode(filename,UnixFileMode.UserRead | UnixFileMode.UserWrite);
+ }
+
+ private static bool HasFileContentDisposition(
+ ContentDispositionHeaderValue contentDisposition)
+ {
+ // Content-Disposition: form-data; name="myfile1"; filename="Misc 002.jpg"
+ return contentDisposition != null &&
+ contentDisposition.DispositionType.Equals("form-data") &&
+ (!string.IsNullOrEmpty(contentDisposition.FileName.Value) ||
+ !string.IsNullOrEmpty(contentDisposition.FileNameStar.Value));
+ }
+
+
+ public async Task DeleteBookBlob(Guid guid)
+ {
+ var path=booksDir+"/"+guid;
+ await Task.Run(() => System.IO.File.Delete(path));
+ }
+
+ public async Task<long> ChangeBookCover(Guid guid, MultipartReader reader)
+ {
+ //if already exists
+ var filename=coversDir+"/"+guid;
+ if ( System.IO.File.Exists(filename)){
+ throw new CommonErrorException(400,"file already exists "+filename ,0);
+ }
+ System.IO.Stream dest;
+ try {
+ dest = System.IO.File.Create (filename);
+ }
+ catch (Exception e)
+ {
+ throw new CommonErrorException(400, "Can't create file for book cover", 0);
+ }
+
+ long coverSize = 0;
+ var section = await reader.ReadNextSectionAsync();
+ while (section != null)
+ {
+ var hasContentDispositionHeader =
+ ContentDispositionHeaderValue.TryParse(
+ section.ContentDisposition,
+ out var contentDisposition);
+
+ if (!hasContentDispositionHeader)
+ continue;
+
+ if (!HasFileContentDisposition(contentDisposition))
+ {
+ var message = "Missing content disposition header";
+ throw new CommonErrorException(400, message, 0);
+ }
+
+ await section.Body.CopyToAsync(dest);
+ coverSize += section.Body.Length;
+
+ section = await reader.ReadNextSectionAsync();
+ }
+ dest.Dispose();
+ System.IO.File.SetUnixFileMode(filename,UnixFileMode.UserRead | UnixFileMode.UserWrite);
+
+ return coverSize;
+ }
+
+ public Task<Stream> DownloadBookCover(Guid guid)
+ {
+ var filename=coversDir+"/"+guid;
+ if (!System.IO.File.Exists(filename)){
+ throw new CommonErrorException(400,"file not exists "+filename ,0);
+ }
+ return Task.FromResult<Stream>(File.OpenRead(filename)); 
+ }
+
+ public async Task DeleteBookCover(Guid guid)
+ {
+ var path=coversDir+"/"+guid;
+ await Task.Run(() => System.IO.File.Delete(path));
+ }
+}

src/Application/Managers/UserLocalStorageManager.cs

@@ -0,0 +1,92 @@
+using Application.Common.Exceptions;
+using Application.Interfaces.Managers;
+using Microsoft.AspNetCore.WebUtilities;
+using Microsoft.Net.Http.Headers;
+
+namespace Application.Managers;
+
+public class UserLocalStorageManager : IUserBlobStorageManager
+{
+ private readonly string _profilePicturePrefix = "profilePicture_";
+ private string dataDir;
+ private string profilesDir;
+ private string baseDir;
+
+ public UserLocalStorageManager()
+ {
+ baseDir=System.Environment.GetFolderPath(System.Environment.SpecialFolder.Personal); // $HOME folder 
+ dataDir= baseDir+"/librum_srorage";
+ profilesDir=dataDir+"/profiles";
+ // create folders
+ if(! System.IO.Directory.Exists(dataDir)) System.IO.Directory.CreateDirectory(dataDir);
+ if(! System.IO.Directory.Exists(profilesDir)) System.IO.Directory.CreateDirectory(profilesDir);
+ Console.WriteLine ("Profile photos directory is "+ profilesDir);
+ }
+
+
+ public Task<Stream> DownloadProfilePicture(string guid)
+ {
+ var filename=profilesDir+"/"+guid;
+ if (!System.IO.File.Exists(filename)){
+ throw new CommonErrorException(400,"file not exists "+filename ,0);
+ }
+ return Task.FromResult<Stream>(File.OpenRead(filename));
+ }
+
+ public async Task ChangeProfilePicture(string guid, MultipartReader reader)
+ {
+ //if already exists
+ var filename=profilesDir+"/"+guid;
+ if ( System.IO.File.Exists(filename)){
+ throw new CommonErrorException(400,"file already exists "+filename ,0);
+ }
+ System.IO.Stream dest;
+ try {
+ dest = System.IO.File.Create (filename);
+ }
+ catch (Exception e)
+ {
+ throw new CommonErrorException(400, "Can't create file "+filename, 0);
+ Console.WriteLine(e.Message);
+ }
+
+ var section = await reader.ReadNextSectionAsync();
+ while (section != null)
+ {
+ var hasContentDispositionHeader =
+ ContentDispositionHeaderValue.TryParse(
+ section.ContentDisposition,
+ out var contentDisposition);
+
+ if (!hasContentDispositionHeader)
+ continue;
+
+ if (!HasFileContentDisposition(contentDisposition))
+ {
+ var message = "Missing content disposition header";
+ throw new CommonErrorException(400, message, 0);
+ }
+
+ await section.Body.CopyToAsync(dest);
+ section = await reader.ReadNextSectionAsync();
+ }
+ dest.Dispose();
+ System.IO.File.SetUnixFileMode(filename,UnixFileMode.UserRead | UnixFileMode.UserWrite);
+ }
+
+ private static bool HasFileContentDisposition(
+ ContentDispositionHeaderValue contentDisposition)
+ {
+ // Content-Disposition: form-data; name="myfile1"; filename="Misc 002.jpg"
+ return contentDisposition != null &&
+ contentDisposition.DispositionType.Equals("form-data") &&
+ (!string.IsNullOrEmpty(contentDisposition.FileName.Value) ||
+ !string.IsNullOrEmpty(contentDisposition.FileNameStar.Value));
+ }
+
+ public async Task DeleteProfilePicture(string guid)
+ {
+ var path=profilesDir+"/"+guid;
+ await Task.Run(() => System.IO.File.Delete(path));
+ }
+}

src/Application/Services/AIService.cs

@@ -34,6 +34,12 @@ public AiService(ILogger<AiService> logger, IHttpClientFactory httpClientFactory
  public async Task ExplainAsync(string email, HttpContext context, string text, 
  string mode)
  {
+ // return error mesage if no OpenAIToken exists for self-hosted mode, dont throw exception
+ if (_configuration["LIBRUM_SELFHOSTED"] == "true" && String.IsNullOrEmpty(_configuration["OpenAIToken"])){
+ await context.Response.WriteAsync("data: " + "OpenAI temporary unavailable" + "\n");
+ return;
+ }
+
  var user = await _userRepository.GetAsync(email, trackChanges: true);
  if(user.AiExplanationRequestsMadeToday >= 10)
  {

src/Application/Utility/EmailSender.cs

@@ -30,7 +30,14 @@ public async Task SendEmailConfirmationEmail(User user, string token)
  var confirmationLink = GetEmailConfirmationLink(user, token);
 
  var message = new MimeMessage();
- message.From.Add (new MailboxAddress ("Librum", "[email protected]"));
+ // message from Librum if not self-hosted
+ if (_configuration["LIBRUM_SELFHOSTED"] != "true"){
+ message.From.Add (new MailboxAddress ("Librum", "[email protected]"));
+ }
+ else{
+ var messFrom = _configuration["SMTPMailFrom"];
+ message.From.Add (new MailboxAddress ("Librum", messFrom));
+ }
  message.To.Add (new MailboxAddress (user.FirstName, user.Email));
  message.Subject = "Confirm Your Email";
 
@@ -47,10 +54,24 @@ public async Task SendEmailConfirmationEmail(User user, string token)
 
  public async Task SendPasswordResetEmail(User user, string token)
  {
- var resetLink = $"https://librumreader.com/resetPassword?email={user.Email}&token={token}";
-
+ // go to librum site if not selfhosted
+ var resetLink = $"https://librumreader.com/resetPassword?email={user.Email}&token={token}";
+ // if self hosted change resetlink
+ if (_configuration["LIBRUM_SELFHOSTED"] == "true"){
+ var domain =_configuration["CleanUrl"];
+ var encodedToken=System.Web.HttpUtility.HtmlEncode(token);
+ resetLink = $"{domain}/user/resetPassword?email={user.Email}&token={encodedToken}";
+ }
+
  var message = new MimeMessage();
- message.From.Add (new MailboxAddress ("Librum", "[email protected]"));
+ // message from librum if not self-hosted
+ if (_configuration["LIBRUM_SELFHOSTED"] != "true"){
+ message.From.Add (new MailboxAddress ("Librum", "[email protected]"));
+ } 
+ else{
+ var messFrom = _configuration["SMTPMailFrom"];
+ message.From.Add (new MailboxAddress ("Librum",messFrom));
+ }
  message.To.Add (new MailboxAddress (user.FirstName, user.Email));
  message.Subject = "Reset Your Password";
 

src/Infrastructure/Persistence/Repository/BookRepository.cs

@@ -82,7 +82,16 @@ private double GetBytesFromSizeString(string size)
  }
 
  var numberString = size.Substring(0, typeBegining);
- var numbers = double.Parse(numberString);
+ // ------------
+ // double.Parse was throwing exception on linux so 
+ //var numbers = double.Parse(numberString,number); 
+ System.Globalization.NumberFormatInfo provider = new System.Globalization.NumberFormatInfo();
+ provider.NumberDecimalSeparator = ".";
+ provider.NumberGroupSeparator = ",";
+ var numbers = Convert.ToDouble(numberString,provider);
+ // end of changes
+ // --------------
+
  var type = size[typeBegining..];
 
  return type.ToLower() switch