Skip to content

Commit

Permalink
refactor (#294)
Browse files Browse the repository at this point in the history
  • Loading branch information
jxnu-liguobin authored Mar 4, 2023
1 parent 2518129 commit 19856e6
Show file tree
Hide file tree
Showing 30 changed files with 321 additions and 543 deletions.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -16,12 +16,12 @@

package org.bitlap.zim.domain

import java.time.ZonedDateTime

import io.circe._
import io.circe.generic.semiauto._
import org.bitlap.zim.domain.model.User

import java.time.ZonedDateTime

/** 返回添加好友、群组消息
*
* @param id
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,14 @@

package org.bitlap.zim

import io.circe._
import zio.schema._

import java.time.ZonedDateTime
import java.time.format.DateTimeFormatter

import scala.util.Try

import io.circe._
import zio.schema._

/** @author
* 梦境迷离
* @since 2022/2/2
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -75,37 +75,7 @@ final class InfrastructureConfiguration {
/** infrastructure dependencies
*/
object InfrastructureConfiguration {
def apply(): InfrastructureConfiguration = new InfrastructureConfiguration()
// ==================================system configuration============================================
val mysqlConfigurationProperties: URIO[InfrastructureConfiguration, MysqlConfigurationProperties] =
ZIO.environmentWith(_.get.mysqlConfigurationProperties)

val zimConfigurationProperties: UIO[ZimConfigurationProperties] =
ZimConfigurationProperties.make

val mailConfigurationProperties: UIO[MailConfigurationProperties] =
MailConfigurationProperties.make

// ==================================数据库============================================
val userRepository: URIO[InfrastructureConfiguration, UserRepository[RStream]] =
ZIO.environmentWith(_.get.userRepository)

val groupRepository: URIO[InfrastructureConfiguration, GroupRepository[RStream]] =
ZIO.environmentWith(_.get.groupRepository)

val receiveRepository: URIO[InfrastructureConfiguration, ReceiveRepository[RStream]] =
ZIO.environmentWith(_.get.receiveRepository)

val friendGroupFriendRepository: URIO[InfrastructureConfiguration, FriendGroupFriendRepository[RStream]] =
ZIO.environmentWith(_.get.friendGroupFriendRepository)

val groupMemberRepository: URIO[InfrastructureConfiguration, GroupMemberRepository[RStream]] =
ZIO.environmentWith(_.get.groupMemberRepository)

val addMessageRepository: URIO[InfrastructureConfiguration, AddMessageRepository[RStream]] =
ZIO.environmentWith(_.get.addMessageRepository)

lazy val layer: ULayer[InfrastructureConfiguration] =
ZLayer.succeed[InfrastructureConfiguration](InfrastructureConfiguration())
lazy val live: ULayer[InfrastructureConfiguration] =
ZLayer.succeed[InfrastructureConfiguration](new InfrastructureConfiguration())

}
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ object MailConfigurationProperties {

private lazy val config: Config = ConfigFactory.load().getConfig("infrastructure.javamail")

def make: UIO[MailConfigurationProperties] = ZIO.succeed(MailConfigurationProperties(config))
lazy val live: ULayer[MailConfigurationProperties] = ZLayer.succeed(MailConfigurationProperties(config))

def apply(config: Config = config): MailConfigurationProperties =
MailConfigurationProperties(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ object ZimConfigurationProperties {

lazy val config: Config = ConfigFactory.load().getConfig("application")

def make: UIO[ZimConfigurationProperties] = ZIO.succeed(ZimConfigurationProperties(config))
lazy val live: ULayer[ZimConfigurationProperties] = ZLayer.succeed(ZimConfigurationProperties(config))

def apply(config: Config = config): ZimConfigurationProperties =
ZimConfigurationProperties(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,10 +16,10 @@

package org.bitlap.zim.infrastructure.util

import zio._

import java.util.UUID

import zio._

/** UUID工具
*
* @since 2021年12月31日
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,9 @@

package org.bitlap.zim.server

import org.bitlap.zim.server.configuration._
import org.bitlap.zim.infrastructure.InfrastructureConfiguration
import org.bitlap.zim.infrastructure.properties.ZimConfigurationProperties
import org.bitlap.zim.server.module._
import zio._

/** main方法
Expand All @@ -25,9 +27,8 @@ import zio._
* 梦境迷离
* @version 1.0,2021/12/24
*/
object ZimServer extends ZimServiceConfiguration with zio.ZIOAppDefault {
object ZimServer extends zio.ZIOAppDefault {
override def run: ZIO[Any, Throwable, Unit] = (for {
routes <- ApiConfiguration.routes
_ <- Console.printLine("""
| ____
| ,--, ,' , `.
Expand All @@ -41,7 +42,14 @@ object ZimServer extends ZimServiceConfiguration with zio.ZIOAppDefault {
| ./__; .' | | '.'|| | |`-'
| ; | .' ; : ;| ;/
| `---' | , / '---'""".stripMargin)
_ <- AkkaHttpConfiguration.httpServer(routes)
} yield ()).provideLayer(AkkaActorSystemConfiguration.live >>> apiConfigurationLayer)

_ <- ZIO.environmentWithZIO[AkkaHttpModule](_.get.httpServer())
_ <- ZIO.never
} yield ()).provide(
AkkaModule.live,
AkkaHttpModule.live,
ServiceModule.live,
InfrastructureConfiguration.live,
ZimConfigurationProperties.live,
Scope.default
)
}

This file was deleted.

This file was deleted.

Loading

0 comments on commit 19856e6

Please sign in to comment.