2317

pending completion

Build # 2317

Build Type

Pull #912

travis-ci

Committed by

web-flow

Commit Message

<a href="https://github.com/outworkers/phantom/commit/<a class=hub.com/outworkers/phantom/commit/4097eb449f1d9f082e65229704767951480a159e">4097eb449<a href="https://github.com/outworkers/phantom/commit/4097eb449f1d9f082e65229704767951480a159e">">Merge </a><a class="double-link" href="https://github.com/outworkers/phantom/commit/<a class="double-link" href="https://github.com/outworkers/phantom/commit/8583bbae48eaae197ee344cc9b4e467d33a9bbbe">8583bbae4</a>">8583bbae4</a><a href="https://github.com/outworkers/phantom/commit/4097eb449f1d9f082e65229704767951480a159e"> into f6d108a82">f6d108a82</a>

Pull Request Pull Request #912: Changing the type of executors used.

Run Details

7 of 7 new or added lines in 4 files covered. (100.0%)

2863 of 3345 relevant lines covered (85.59%)

2.56 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

92.86

/phantom-dsl/src/main/scala/com/outworkers/phantom/jdk8/indexed/package.scala

/*
 * Copyright 2013 - 2020 Outworkers Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.outworkers.phantom.jdk8

import java.time.{LocalDate => JavaLocalDate, LocalDateTime => JavaLocalDateTime, _}

import com.datastax.driver.core.{LocalDate => DatastaxLocalDate}
import com.outworkers.phantom.builder.primitives.Primitive
import com.outworkers.phantom.builder.syntax.CQLSyntax
import org.joda.time.{DateTime, DateTimeZone}

package object indexed {

  implicit val OffsetDateTimeIsPrimitive: Primitive[OffsetDateTime] = Primitive.manuallyDerive[OffsetDateTime, Long](
    _.toInstant.toEpochMilli,
    millis => OffsetDateTime.ofInstant(Instant.ofEpochMilli(millis), ZoneOffset.UTC)
  )(Primitive[Long])(CQLSyntax.Types.Timestamp)

  implicit val zonePrimitive: Primitive[ZoneId] = Primitive.derive[ZoneId, String](_.getId)(ZoneId.of)

  implicit val LocalDateIsPrimitive: Primitive[JavaLocalDate] = Primitive.manuallyDerive[JavaLocalDate, DatastaxLocalDate](
    l => {
      val off = OffsetDateTime.of(l.atTime(0, 0), ZoneOffset.UTC)
      DatastaxLocalDate.fromYearMonthDay(off.getYear, off.getMonthValue, off.getDayOfMonth)
    }, s => {
      val conv = OffsetDateTime.ofInstant(Instant.ofEpochMilli(s.getMillisSinceEpoch), ZoneOffset.UTC)
      JavaLocalDate.of(conv.getYear, conv.getMonth, conv.getDayOfMonth)
    }

  )(Primitive[DatastaxLocalDate])(CQLSyntax.Types.Date)

  implicit val zonedDateTimePrimitive: Primitive[ZonedDateTime] = Primitive.manuallyDerive[ZonedDateTime, Instant](
    _.toInstant,
    ZonedDateTime.ofInstant(_, ZoneOffset.UTC)
  )(instantPrimitive)(CQLSyntax.Types.Timestamp)

  implicit val JdkLocalDateTimeIsPrimitive: Primitive[JavaLocalDateTime] = {
    Primitive.derive[JavaLocalDateTime, DateTime](jd =>
      new DateTime(jd.toInstant(ZoneOffset.UTC).toEpochMilli, DateTimeZone.UTC)
    )(dt => JavaLocalDateTime.ofInstant(Instant.ofEpochMilli(dt.getMillis), ZoneOffset.UTC))
  }

}

1	/*
2	* Copyright 2013 - 2020 Outworkers Ltd.
3	*
4	* Licensed under the Apache License, Version 2.0 (the "License");
5	* you may not use this file except in compliance with the License.
6	* You may obtain a copy of the License at
7	*
8	* http://www.apache.org/licenses/LICENSE-2.0
9	*
10	* Unless required by applicable law or agreed to in writing, software
11	* distributed under the License is distributed on an "AS IS" BASIS,
12	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13	* See the License for the specific language governing permissions and
14	* limitations under the License.
15	*/
16	package com.outworkers.phantom.jdk8
17
18	import java.time.{LocalDate => JavaLocalDate, LocalDateTime => JavaLocalDateTime, _}
19
20	import com.datastax.driver.core.{LocalDate => DatastaxLocalDate}
21	import com.outworkers.phantom.builder.primitives.Primitive
22	import com.outworkers.phantom.builder.syntax.CQLSyntax
23	import org.joda.time.{DateTime, DateTimeZone}
24
25	package object indexed {
26
27	implicit val OffsetDateTimeIsPrimitive: Primitive[OffsetDateTime] = Primitive.manuallyDerive[OffsetDateTime, Long](
28	_.toInstant.toEpochMilli,	3✔
29	millis => OffsetDateTime.ofInstant(Instant.ofEpochMilli(millis), ZoneOffset.UTC)	3✔
30	)(Primitive[Long])(CQLSyntax.Types.Timestamp)	3✔
31
32	implicit val zonePrimitive: Primitive[ZoneId] = Primitive.derive[ZoneId, String](_.getId)(ZoneId.of)	×
33
34	implicit val LocalDateIsPrimitive: Primitive[JavaLocalDate] = Primitive.manuallyDerive[JavaLocalDate, DatastaxLocalDate](
35	l => {
36	val off = OffsetDateTime.of(l.atTime(0, 0), ZoneOffset.UTC)	3✔
37	DatastaxLocalDate.fromYearMonthDay(off.getYear, off.getMonthValue, off.getDayOfMonth)	3✔
38	}, s => {
39	val conv = OffsetDateTime.ofInstant(Instant.ofEpochMilli(s.getMillisSinceEpoch), ZoneOffset.UTC)	3✔
40	JavaLocalDate.of(conv.getYear, conv.getMonth, conv.getDayOfMonth)	3✔
41	}
42
43	)(Primitive[DatastaxLocalDate])(CQLSyntax.Types.Date)	3✔
44
45	implicit val zonedDateTimePrimitive: Primitive[ZonedDateTime] = Primitive.manuallyDerive[ZonedDateTime, Instant](
46	_.toInstant,	3✔
47	ZonedDateTime.ofInstant(_, ZoneOffset.UTC)	3✔
48	)(instantPrimitive)(CQLSyntax.Types.Timestamp)	3✔
49
50	implicit val JdkLocalDateTimeIsPrimitive: Primitive[JavaLocalDateTime] = {
51	Primitive.derive[JavaLocalDateTime, DateTime](jd =>
52	new DateTime(jd.toInstant(ZoneOffset.UTC).toEpochMilli, DateTimeZone.UTC)	3✔
53	)(dt => JavaLocalDateTime.ofInstant(Instant.ofEpochMilli(dt.getMillis), ZoneOffset.UTC))	3✔
54	}
55
56	}

outworkers / phantom / 2317

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous