Compare commits
1 Commits
master
...
dependabot
| Author | SHA1 | Date | |
|---|---|---|---|
|
4b7d452eae |
@@ -87,7 +87,6 @@ if [[ "$MODULE" == "module7" ]]
|
||||
then
|
||||
# ADD NEW MODULES HERE
|
||||
# (add new modules above the rest so you get quicker feedback if it fails)
|
||||
build_gradle_module "kotlin/coroutines"
|
||||
build_maven_module "core-java/streams/data-streams"
|
||||
build maven_module "aws/kinesis"
|
||||
build maven_module "aws/sqs"
|
||||
|
||||
29
core-java/jackson/jackson/.gitignore
vendored
29
core-java/jackson/jackson/.gitignore
vendored
@@ -1,29 +0,0 @@
|
||||
HELP.md
|
||||
target/*
|
||||
!.mvn/wrapper/maven-wrapper.jar
|
||||
!**/src/main/**/target/
|
||||
!**/src/test/**/target/
|
||||
|
||||
.classpath
|
||||
.factorypath
|
||||
.project
|
||||
.settings
|
||||
.springBeans
|
||||
|
||||
### IntelliJ IDEA ###
|
||||
.idea
|
||||
*.iws
|
||||
*.iml
|
||||
*.ipr
|
||||
|
||||
### NetBeans ###
|
||||
/nbproject/private/
|
||||
/nbbuild/
|
||||
/dist/
|
||||
/nbdist/
|
||||
build/
|
||||
!**/src/main/**/build/
|
||||
!**/src/test/**/build/
|
||||
|
||||
### VS Code ###
|
||||
.vscode/
|
||||
@@ -1,52 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0"
|
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<groupId>com.reflectoring</groupId>
|
||||
<artifactId>jackson</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
|
||||
<properties>
|
||||
<maven.compiler.source>11</maven.compiler.source>
|
||||
<maven.compiler.target>11</maven.compiler.target>
|
||||
</properties>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>com.fasterxml.jackson.core</groupId>
|
||||
<artifactId>jackson-databind</artifactId>
|
||||
<version>2.13.3</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>com.fasterxml.jackson.datatype</groupId>
|
||||
<artifactId>jackson-datatype-jsr310</artifactId>
|
||||
<version>2.13.3</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.junit.jupiter</groupId>
|
||||
<artifactId>junit-jupiter-api</artifactId>
|
||||
<version>5.9.0-M1</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.projectlombok</groupId>
|
||||
<artifactId>lombok</artifactId>
|
||||
<version>1.18.24</version>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.assertj</groupId>
|
||||
<artifactId>assertj-core</artifactId>
|
||||
<version>3.23.1</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
|
||||
</dependencies>
|
||||
</project>
|
||||
@@ -1,24 +0,0 @@
|
||||
package com.reflectoring.pojo;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonAnySetter;
|
||||
import com.fasterxml.jackson.annotation.JsonSetter;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Getter;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
@NoArgsConstructor
|
||||
@AllArgsConstructor
|
||||
@Getter
|
||||
public class Car {
|
||||
@JsonSetter("carBrand")
|
||||
private String brand;
|
||||
private Map<String, String> unrecognizedFields = new HashMap<>();
|
||||
|
||||
@JsonAnySetter
|
||||
public void allSetter(String fieldName, String fieldValue) {
|
||||
unrecognizedFields.put(fieldName, fieldValue);
|
||||
}
|
||||
}
|
||||
@@ -1,29 +0,0 @@
|
||||
package com.reflectoring.pojo;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonAnyGetter;
|
||||
import com.fasterxml.jackson.annotation.JsonGetter;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
@NoArgsConstructor
|
||||
@AllArgsConstructor
|
||||
public class Cat {
|
||||
private String name;
|
||||
|
||||
@JsonAnyGetter
|
||||
Map<String, String> map = Map.of(
|
||||
"name", "Jack",
|
||||
"surname", "wolfskin"
|
||||
);
|
||||
|
||||
@JsonGetter("catName")
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public Cat(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
}
|
||||
@@ -1,15 +0,0 @@
|
||||
package com.reflectoring.pojo;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonIgnore;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Getter;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
@Getter
|
||||
public class Dog {
|
||||
private String name;
|
||||
@JsonIgnore
|
||||
private Integer age;
|
||||
}
|
||||
@@ -1,16 +0,0 @@
|
||||
package com.reflectoring.pojo;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Getter;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
@Getter
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
public class Employee {
|
||||
private String firstName;
|
||||
private String lastName;
|
||||
private int age;
|
||||
}
|
||||
@@ -1,18 +0,0 @@
|
||||
package com.reflectoring.pojo;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import com.fasterxml.jackson.annotation.JsonSetter;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Getter;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
import java.time.LocalDate;
|
||||
|
||||
@NoArgsConstructor
|
||||
@AllArgsConstructor
|
||||
@Getter
|
||||
public class Order {
|
||||
private int id;
|
||||
@JsonFormat(pattern = "dd/MM/yyyy")
|
||||
private LocalDate date;
|
||||
}
|
||||
@@ -1,184 +0,0 @@
|
||||
package com.reflectoring;
|
||||
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
import com.fasterxml.jackson.core.type.TypeReference;
|
||||
import com.fasterxml.jackson.databind.DeserializationFeature;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import com.reflectoring.pojo.*;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.time.LocalDate;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
public class JacksonTest {
|
||||
ObjectMapper objectMapper = new ObjectMapper().findAndRegisterModules();
|
||||
|
||||
@Test
|
||||
void jsonStringToPojo() throws JsonProcessingException {
|
||||
String employeeJson = "{\n" +
|
||||
" \"firstName\" : \"Jalil\",\n" +
|
||||
" \"lastName\" : \"Jarjanazy\",\n" +
|
||||
" \"age\" : 30\n" +
|
||||
"}";
|
||||
|
||||
Employee employee = objectMapper.readValue(employeeJson, Employee.class);
|
||||
|
||||
assertThat(employee.getFirstName()).isEqualTo("Jalil");
|
||||
}
|
||||
|
||||
@Test
|
||||
void pojoToJsonString() throws JsonProcessingException {
|
||||
Employee employee = new Employee("Mark", "James", 20);
|
||||
|
||||
String json = objectMapper.writeValueAsString(employee);
|
||||
|
||||
assertThat(json).isEqualTo("{\"firstName\":\"Mark\",\"lastName\":\"James\",\"age\":20}");
|
||||
}
|
||||
|
||||
@Test
|
||||
void jsonFileToPojo() throws IOException {
|
||||
File file = new File("src/test/resources/employee.json");
|
||||
|
||||
Employee employee = objectMapper.readValue(file, Employee.class);
|
||||
|
||||
assertThat(employee.getAge()).isEqualTo(44);
|
||||
assertThat(employee.getLastName()).isEqualTo("Simpson");
|
||||
assertThat(employee.getFirstName()).isEqualTo("Homer");
|
||||
}
|
||||
|
||||
@Test
|
||||
void byteArrayToPojo() throws IOException {
|
||||
String employeeJson = "{\n" +
|
||||
" \"firstName\" : \"Jalil\",\n" +
|
||||
" \"lastName\" : \"Jarjanazy\",\n" +
|
||||
" \"age\" : 30\n" +
|
||||
"}";
|
||||
|
||||
Employee employee = objectMapper.readValue(employeeJson.getBytes(), Employee.class);
|
||||
|
||||
assertThat(employee.getFirstName()).isEqualTo("Jalil");
|
||||
}
|
||||
|
||||
@Test
|
||||
void fileToListOfPojos() throws IOException {
|
||||
File file = new File("src/test/resources/employeeList.json");
|
||||
List<Employee> employeeList = objectMapper.readValue(file, new TypeReference<>(){});
|
||||
|
||||
assertThat(employeeList).hasSize(2);
|
||||
assertThat(employeeList.get(0).getAge()).isEqualTo(33);
|
||||
assertThat(employeeList.get(0).getLastName()).isEqualTo("Simpson");
|
||||
assertThat(employeeList.get(0).getFirstName()).isEqualTo("Marge");
|
||||
}
|
||||
|
||||
@Test
|
||||
void fileToMap() throws IOException {
|
||||
File file = new File("src/test/resources/employee.json");
|
||||
Map<String, Object> employee = objectMapper.readValue(file, new TypeReference<>(){});
|
||||
|
||||
assertThat(employee.keySet()).containsExactly("firstName", "lastName", "age");
|
||||
|
||||
assertThat(employee.get("firstName")).isEqualTo("Homer");
|
||||
assertThat(employee.get("lastName")).isEqualTo("Simpson");
|
||||
assertThat(employee.get("age")).isEqualTo(44);
|
||||
}
|
||||
|
||||
@Test
|
||||
void fileToPojoWithUnknownProperties() throws IOException {
|
||||
File file = new File("src/test/resources/employeeWithUnknownProperties.json");
|
||||
|
||||
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
|
||||
|
||||
Employee employee = objectMapper.readValue(file, Employee.class);
|
||||
|
||||
assertThat(employee.getFirstName()).isEqualTo("Homer");
|
||||
assertThat(employee.getLastName()).isEqualTo("Simpson");
|
||||
assertThat(employee.getAge()).isEqualTo(44);
|
||||
}
|
||||
|
||||
@Test
|
||||
void orderToJson() throws JsonProcessingException {
|
||||
Order order = new Order(1, LocalDate.of(1900,2,1));
|
||||
|
||||
String json = objectMapper.writeValueAsString(order);
|
||||
|
||||
System.out.println(json);
|
||||
}
|
||||
|
||||
@Test
|
||||
void orderToJsonWithDate() throws JsonProcessingException {
|
||||
Order order = new Order(1, LocalDate.of(2023, 1, 1));
|
||||
|
||||
String json = objectMapper.writeValueAsString(order);
|
||||
|
||||
System.out.println(json);
|
||||
}
|
||||
@Test
|
||||
void fileToOrder() throws IOException {
|
||||
File file = new File("src/test/resources/order.json");
|
||||
|
||||
Order order = objectMapper.readValue(file, Order.class);
|
||||
|
||||
assertThat(order.getDate().getYear()).isEqualTo(2000);
|
||||
assertThat(order.getDate().getMonthValue()).isEqualTo(4);
|
||||
assertThat(order.getDate().getDayOfMonth()).isEqualTo(30);
|
||||
}
|
||||
@Test
|
||||
void fileToCar() throws IOException {
|
||||
File file = new File("src/test/resources/car.json");
|
||||
|
||||
Car car = objectMapper.readValue(file, Car.class);
|
||||
|
||||
assertThat(car.getBrand()).isEqualTo("BMW");
|
||||
}
|
||||
|
||||
@Test
|
||||
void fileToUnrecognizedCar() throws IOException {
|
||||
File file = new File("src/test/resources/carUnrecognized.json");
|
||||
|
||||
Car car = objectMapper.readValue(file, Car.class);
|
||||
|
||||
assertThat(car.getUnrecognizedFields()).containsKey("productionYear");
|
||||
}
|
||||
|
||||
@Test
|
||||
void catToJson() throws JsonProcessingException {
|
||||
Cat cat = new Cat("Monica");
|
||||
|
||||
String json = objectMapper.writeValueAsString(cat);
|
||||
|
||||
System.out.println(json);
|
||||
|
||||
}
|
||||
|
||||
@Test
|
||||
void catToJsonWithMap() throws JsonProcessingException {
|
||||
Cat cat = new Cat("Monica");
|
||||
|
||||
String json = objectMapper.writeValueAsString(cat);
|
||||
|
||||
System.out.println(json);
|
||||
}
|
||||
|
||||
@Test
|
||||
void dogToJson() throws JsonProcessingException {
|
||||
Dog dog = new Dog("Max", 3);
|
||||
|
||||
String json = objectMapper.writeValueAsString(dog);
|
||||
|
||||
System.out.println(json);
|
||||
}
|
||||
@Test
|
||||
void fileToDog() throws IOException {
|
||||
File file = new File("src/test/resources/dog.json");
|
||||
|
||||
Dog dog = objectMapper.readValue(file, Dog.class);
|
||||
|
||||
assertThat(dog.getName()).isEqualTo("bobby");
|
||||
assertThat(dog.getAge()).isNull();
|
||||
}
|
||||
}
|
||||
@@ -1,3 +0,0 @@
|
||||
{
|
||||
"carBrand" : "BMW"
|
||||
}
|
||||
@@ -1,4 +0,0 @@
|
||||
{
|
||||
"carBrand" : "BMW",
|
||||
"productionYear": 1996
|
||||
}
|
||||
@@ -1,4 +0,0 @@
|
||||
{
|
||||
"name" : "bobby",
|
||||
"age" : 5
|
||||
}
|
||||
@@ -1,5 +0,0 @@
|
||||
{
|
||||
"firstName":"Homer",
|
||||
"lastName":"Simpson",
|
||||
"age":44
|
||||
}
|
||||
@@ -1,12 +0,0 @@
|
||||
[
|
||||
{
|
||||
"firstName":"Marge",
|
||||
"lastName":"Simpson",
|
||||
"age":33
|
||||
},
|
||||
{
|
||||
"firstName":"Homer",
|
||||
"lastName":"Simpson",
|
||||
"age":44
|
||||
}
|
||||
]
|
||||
@@ -1,6 +0,0 @@
|
||||
{
|
||||
"firstName":"Homer",
|
||||
"lastName":"Simpson",
|
||||
"age":44,
|
||||
"department": "IT"
|
||||
}
|
||||
@@ -1,4 +0,0 @@
|
||||
{
|
||||
"id" : 1,
|
||||
"date" : "30/04/2000"
|
||||
}
|
||||
@@ -1,8 +0,0 @@
|
||||
# Maven
|
||||
target/
|
||||
.mvn/
|
||||
|
||||
# eclipse project file
|
||||
.settings/
|
||||
.classpath
|
||||
.project
|
||||
@@ -1,3 +0,0 @@
|
||||
# Related Blog Posts
|
||||
|
||||
* [Parameterized tests with JUnit 5](https://reflectoring.io/junit5-parameterized-tests/)
|
||||
287
core-java/junit5-parameterized-tests/mvnw
vendored
287
core-java/junit5-parameterized-tests/mvnw
vendored
@@ -1,287 +0,0 @@
|
||||
#!/bin/sh
|
||||
# ----------------------------------------------------------------------------
|
||||
# Licensed to the Apache Software Foundation (ASF) under one
|
||||
# or more contributor license agreements. See the NOTICE file
|
||||
# distributed with this work for additional information
|
||||
# regarding copyright ownership. The ASF licenses this file
|
||||
# to you 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.
|
||||
# ----------------------------------------------------------------------------
|
||||
|
||||
# ----------------------------------------------------------------------------
|
||||
# Apache Maven Wrapper startup batch script, version 3.1.1
|
||||
#
|
||||
# Required ENV vars:
|
||||
# ------------------
|
||||
# JAVA_HOME - location of a JDK home dir
|
||||
#
|
||||
# Optional ENV vars
|
||||
# -----------------
|
||||
# MAVEN_OPTS - parameters passed to the Java VM when running Maven
|
||||
# e.g. to debug Maven itself, use
|
||||
# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
|
||||
# MAVEN_SKIP_RC - flag to disable loading of mavenrc files
|
||||
# ----------------------------------------------------------------------------
|
||||
|
||||
if [ -z "$MAVEN_SKIP_RC" ] ; then
|
||||
|
||||
if [ -f /usr/local/etc/mavenrc ] ; then
|
||||
. /usr/local/etc/mavenrc
|
||||
fi
|
||||
|
||||
if [ -f /etc/mavenrc ] ; then
|
||||
. /etc/mavenrc
|
||||
fi
|
||||
|
||||
if [ -f "$HOME/.mavenrc" ] ; then
|
||||
. "$HOME/.mavenrc"
|
||||
fi
|
||||
|
||||
fi
|
||||
|
||||
# OS specific support. $var _must_ be set to either true or false.
|
||||
cygwin=false;
|
||||
darwin=false;
|
||||
mingw=false
|
||||
case "`uname`" in
|
||||
CYGWIN*) cygwin=true ;;
|
||||
MINGW*) mingw=true;;
|
||||
Darwin*) darwin=true
|
||||
# Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
|
||||
# See https://developer.apple.com/library/mac/qa/qa1170/_index.html
|
||||
if [ -z "$JAVA_HOME" ]; then
|
||||
if [ -x "/usr/libexec/java_home" ]; then
|
||||
JAVA_HOME="`/usr/libexec/java_home`"; export JAVA_HOME
|
||||
else
|
||||
JAVA_HOME="/Library/Java/Home"; export JAVA_HOME
|
||||
fi
|
||||
fi
|
||||
;;
|
||||
esac
|
||||
|
||||
if [ -z "$JAVA_HOME" ] ; then
|
||||
if [ -r /etc/gentoo-release ] ; then
|
||||
JAVA_HOME=`java-config --jre-home`
|
||||
fi
|
||||
fi
|
||||
|
||||
# For Cygwin, ensure paths are in UNIX format before anything is touched
|
||||
if $cygwin ; then
|
||||
[ -n "$JAVA_HOME" ] &&
|
||||
JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
|
||||
[ -n "$CLASSPATH" ] &&
|
||||
CLASSPATH=`cygpath --path --unix "$CLASSPATH"`
|
||||
fi
|
||||
|
||||
# For Mingw, ensure paths are in UNIX format before anything is touched
|
||||
if $mingw ; then
|
||||
[ -n "$JAVA_HOME" ] &&
|
||||
JAVA_HOME="`(cd "$JAVA_HOME"; pwd)`"
|
||||
fi
|
||||
|
||||
if [ -z "$JAVA_HOME" ]; then
|
||||
javaExecutable="`which javac`"
|
||||
if [ -n "$javaExecutable" ] && ! [ "`expr \"$javaExecutable\" : '\([^ ]*\)'`" = "no" ]; then
|
||||
# readlink(1) is not available as standard on Solaris 10.
|
||||
readLink=`which readlink`
|
||||
if [ ! `expr "$readLink" : '\([^ ]*\)'` = "no" ]; then
|
||||
if $darwin ; then
|
||||
javaHome="`dirname \"$javaExecutable\"`"
|
||||
javaExecutable="`cd \"$javaHome\" && pwd -P`/javac"
|
||||
else
|
||||
javaExecutable="`readlink -f \"$javaExecutable\"`"
|
||||
fi
|
||||
javaHome="`dirname \"$javaExecutable\"`"
|
||||
javaHome=`expr "$javaHome" : '\(.*\)/bin'`
|
||||
JAVA_HOME="$javaHome"
|
||||
export JAVA_HOME
|
||||
fi
|
||||
fi
|
||||
fi
|
||||
|
||||
if [ -z "$JAVACMD" ] ; then
|
||||
if [ -n "$JAVA_HOME" ] ; then
|
||||
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
|
||||
# IBM's JDK on AIX uses strange locations for the executables
|
||||
JAVACMD="$JAVA_HOME/jre/sh/java"
|
||||
else
|
||||
JAVACMD="$JAVA_HOME/bin/java"
|
||||
fi
|
||||
else
|
||||
JAVACMD="`\\unset -f command; \\command -v java`"
|
||||
fi
|
||||
fi
|
||||
|
||||
if [ ! -x "$JAVACMD" ] ; then
|
||||
echo "Error: JAVA_HOME is not defined correctly." >&2
|
||||
echo " We cannot execute $JAVACMD" >&2
|
||||
exit 1
|
||||
fi
|
||||
|
||||
if [ -z "$JAVA_HOME" ] ; then
|
||||
echo "Warning: JAVA_HOME environment variable is not set."
|
||||
fi
|
||||
|
||||
# traverses directory structure from process work directory to filesystem root
|
||||
# first directory with .mvn subdirectory is considered project base directory
|
||||
find_maven_basedir() {
|
||||
if [ -z "$1" ]
|
||||
then
|
||||
echo "Path not specified to find_maven_basedir"
|
||||
return 1
|
||||
fi
|
||||
|
||||
basedir="$1"
|
||||
wdir="$1"
|
||||
while [ "$wdir" != '/' ] ; do
|
||||
if [ -d "$wdir"/.mvn ] ; then
|
||||
basedir=$wdir
|
||||
break
|
||||
fi
|
||||
# workaround for JBEAP-8937 (on Solaris 10/Sparc)
|
||||
if [ -d "${wdir}" ]; then
|
||||
wdir=`cd "$wdir/.."; pwd`
|
||||
fi
|
||||
# end of workaround
|
||||
done
|
||||
printf '%s' "$(cd "$basedir"; pwd)"
|
||||
}
|
||||
|
||||
# concatenates all lines of a file
|
||||
concat_lines() {
|
||||
if [ -f "$1" ]; then
|
||||
echo "$(tr -s '\n' ' ' < "$1")"
|
||||
fi
|
||||
}
|
||||
|
||||
BASE_DIR=$(find_maven_basedir "$(dirname $0)")
|
||||
if [ -z "$BASE_DIR" ]; then
|
||||
exit 1;
|
||||
fi
|
||||
|
||||
MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}; export MAVEN_PROJECTBASEDIR
|
||||
if [ "$MVNW_VERBOSE" = true ]; then
|
||||
echo $MAVEN_PROJECTBASEDIR
|
||||
fi
|
||||
|
||||
##########################################################################################
|
||||
# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
|
||||
# This allows using the maven wrapper in projects that prohibit checking in binary data.
|
||||
##########################################################################################
|
||||
if [ -r "$BASE_DIR/.mvn/wrapper/maven-wrapper.jar" ]; then
|
||||
if [ "$MVNW_VERBOSE" = true ]; then
|
||||
echo "Found .mvn/wrapper/maven-wrapper.jar"
|
||||
fi
|
||||
else
|
||||
if [ "$MVNW_VERBOSE" = true ]; then
|
||||
echo "Couldn't find .mvn/wrapper/maven-wrapper.jar, downloading it ..."
|
||||
fi
|
||||
if [ -n "$MVNW_REPOURL" ]; then
|
||||
wrapperUrl="$MVNW_REPOURL/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar"
|
||||
else
|
||||
wrapperUrl="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar"
|
||||
fi
|
||||
while IFS="=" read key value; do
|
||||
case "$key" in (wrapperUrl) wrapperUrl="$value"; break ;;
|
||||
esac
|
||||
done < "$BASE_DIR/.mvn/wrapper/maven-wrapper.properties"
|
||||
if [ "$MVNW_VERBOSE" = true ]; then
|
||||
echo "Downloading from: $wrapperUrl"
|
||||
fi
|
||||
wrapperJarPath="$BASE_DIR/.mvn/wrapper/maven-wrapper.jar"
|
||||
if $cygwin; then
|
||||
wrapperJarPath=`cygpath --path --windows "$wrapperJarPath"`
|
||||
fi
|
||||
|
||||
if command -v wget > /dev/null; then
|
||||
QUIET="--quiet"
|
||||
if [ "$MVNW_VERBOSE" = true ]; then
|
||||
echo "Found wget ... using wget"
|
||||
QUIET=""
|
||||
fi
|
||||
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
|
||||
wget $QUIET "$wrapperUrl" -O "$wrapperJarPath"
|
||||
else
|
||||
wget $QUIET --http-user="$MVNW_USERNAME" --http-password="$MVNW_PASSWORD" "$wrapperUrl" -O "$wrapperJarPath"
|
||||
fi
|
||||
[ $? -eq 0 ] || rm -f "$wrapperJarPath"
|
||||
elif command -v curl > /dev/null; then
|
||||
QUIET="--silent"
|
||||
if [ "$MVNW_VERBOSE" = true ]; then
|
||||
echo "Found curl ... using curl"
|
||||
QUIET=""
|
||||
fi
|
||||
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
|
||||
curl $QUIET -o "$wrapperJarPath" "$wrapperUrl" -f -L
|
||||
else
|
||||
curl $QUIET --user "$MVNW_USERNAME:$MVNW_PASSWORD" -o "$wrapperJarPath" "$wrapperUrl" -f -L
|
||||
fi
|
||||
[ $? -eq 0 ] || rm -f "$wrapperJarPath"
|
||||
else
|
||||
if [ "$MVNW_VERBOSE" = true ]; then
|
||||
echo "Falling back to using Java to download"
|
||||
fi
|
||||
javaSource="$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.java"
|
||||
javaClass="$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class"
|
||||
# For Cygwin, switch paths to Windows format before running javac
|
||||
if $cygwin; then
|
||||
javaSource=`cygpath --path --windows "$javaSource"`
|
||||
javaClass=`cygpath --path --windows "$javaClass"`
|
||||
fi
|
||||
if [ -e "$javaSource" ]; then
|
||||
if [ ! -e "$javaClass" ]; then
|
||||
if [ "$MVNW_VERBOSE" = true ]; then
|
||||
echo " - Compiling MavenWrapperDownloader.java ..."
|
||||
fi
|
||||
# Compiling the Java class
|
||||
("$JAVA_HOME/bin/javac" "$javaSource")
|
||||
fi
|
||||
if [ -e "$javaClass" ]; then
|
||||
# Running the downloader
|
||||
if [ "$MVNW_VERBOSE" = true ]; then
|
||||
echo " - Running MavenWrapperDownloader.java ..."
|
||||
fi
|
||||
("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$MAVEN_PROJECTBASEDIR")
|
||||
fi
|
||||
fi
|
||||
fi
|
||||
fi
|
||||
##########################################################################################
|
||||
# End of extension
|
||||
##########################################################################################
|
||||
|
||||
MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"
|
||||
|
||||
# For Cygwin, switch paths to Windows format before running java
|
||||
if $cygwin; then
|
||||
[ -n "$JAVA_HOME" ] &&
|
||||
JAVA_HOME=`cygpath --path --windows "$JAVA_HOME"`
|
||||
[ -n "$CLASSPATH" ] &&
|
||||
CLASSPATH=`cygpath --path --windows "$CLASSPATH"`
|
||||
[ -n "$MAVEN_PROJECTBASEDIR" ] &&
|
||||
MAVEN_PROJECTBASEDIR=`cygpath --path --windows "$MAVEN_PROJECTBASEDIR"`
|
||||
fi
|
||||
|
||||
# Provide a "standardized" way to retrieve the CLI args that will
|
||||
# work with both Windows and non-Windows executions.
|
||||
MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $@"
|
||||
export MAVEN_CMD_LINE_ARGS
|
||||
|
||||
WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
|
||||
|
||||
exec "$JAVACMD" \
|
||||
$MAVEN_OPTS \
|
||||
$MAVEN_DEBUG_OPTS \
|
||||
-classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
|
||||
"-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
|
||||
${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@"
|
||||
187
core-java/junit5-parameterized-tests/mvnw.cmd
vendored
187
core-java/junit5-parameterized-tests/mvnw.cmd
vendored
@@ -1,187 +0,0 @@
|
||||
@REM ----------------------------------------------------------------------------
|
||||
@REM Licensed to the Apache Software Foundation (ASF) under one
|
||||
@REM or more contributor license agreements. See the NOTICE file
|
||||
@REM distributed with this work for additional information
|
||||
@REM regarding copyright ownership. The ASF licenses this file
|
||||
@REM to you under the Apache License, Version 2.0 (the
|
||||
@REM "License"); you may not use this file except in compliance
|
||||
@REM with the License. You may obtain a copy of the License at
|
||||
@REM
|
||||
@REM http://www.apache.org/licenses/LICENSE-2.0
|
||||
@REM
|
||||
@REM Unless required by applicable law or agreed to in writing,
|
||||
@REM software distributed under the License is distributed on an
|
||||
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||
@REM KIND, either express or implied. See the License for the
|
||||
@REM specific language governing permissions and limitations
|
||||
@REM under the License.
|
||||
@REM ----------------------------------------------------------------------------
|
||||
|
||||
@REM ----------------------------------------------------------------------------
|
||||
@REM Apache Maven Wrapper startup batch script, version 3.1.1
|
||||
@REM
|
||||
@REM Required ENV vars:
|
||||
@REM JAVA_HOME - location of a JDK home dir
|
||||
@REM
|
||||
@REM Optional ENV vars
|
||||
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
|
||||
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
|
||||
@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
|
||||
@REM e.g. to debug Maven itself, use
|
||||
@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
|
||||
@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
|
||||
@REM ----------------------------------------------------------------------------
|
||||
|
||||
@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
|
||||
@echo off
|
||||
@REM set title of command window
|
||||
title %0
|
||||
@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
|
||||
@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
|
||||
|
||||
@REM set %HOME% to equivalent of $HOME
|
||||
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
|
||||
|
||||
@REM Execute a user defined script before this one
|
||||
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
|
||||
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
|
||||
if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
|
||||
if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
|
||||
:skipRcPre
|
||||
|
||||
@setlocal
|
||||
|
||||
set ERROR_CODE=0
|
||||
|
||||
@REM To isolate internal variables from possible post scripts, we use another setlocal
|
||||
@setlocal
|
||||
|
||||
@REM ==== START VALIDATION ====
|
||||
if not "%JAVA_HOME%" == "" goto OkJHome
|
||||
|
||||
echo.
|
||||
echo Error: JAVA_HOME not found in your environment. >&2
|
||||
echo Please set the JAVA_HOME variable in your environment to match the >&2
|
||||
echo location of your Java installation. >&2
|
||||
echo.
|
||||
goto error
|
||||
|
||||
:OkJHome
|
||||
if exist "%JAVA_HOME%\bin\java.exe" goto init
|
||||
|
||||
echo.
|
||||
echo Error: JAVA_HOME is set to an invalid directory. >&2
|
||||
echo JAVA_HOME = "%JAVA_HOME%" >&2
|
||||
echo Please set the JAVA_HOME variable in your environment to match the >&2
|
||||
echo location of your Java installation. >&2
|
||||
echo.
|
||||
goto error
|
||||
|
||||
@REM ==== END VALIDATION ====
|
||||
|
||||
:init
|
||||
|
||||
@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
|
||||
@REM Fallback to current working directory if not found.
|
||||
|
||||
set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
|
||||
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
|
||||
|
||||
set EXEC_DIR=%CD%
|
||||
set WDIR=%EXEC_DIR%
|
||||
:findBaseDir
|
||||
IF EXIST "%WDIR%"\.mvn goto baseDirFound
|
||||
cd ..
|
||||
IF "%WDIR%"=="%CD%" goto baseDirNotFound
|
||||
set WDIR=%CD%
|
||||
goto findBaseDir
|
||||
|
||||
:baseDirFound
|
||||
set MAVEN_PROJECTBASEDIR=%WDIR%
|
||||
cd "%EXEC_DIR%"
|
||||
goto endDetectBaseDir
|
||||
|
||||
:baseDirNotFound
|
||||
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
|
||||
cd "%EXEC_DIR%"
|
||||
|
||||
:endDetectBaseDir
|
||||
|
||||
IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
|
||||
|
||||
@setlocal EnableExtensions EnableDelayedExpansion
|
||||
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
|
||||
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
|
||||
|
||||
:endReadAdditionalConfig
|
||||
|
||||
SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
|
||||
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
|
||||
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
|
||||
|
||||
set WRAPPER_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar"
|
||||
|
||||
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
|
||||
IF "%%A"=="wrapperUrl" SET WRAPPER_URL=%%B
|
||||
)
|
||||
|
||||
@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
|
||||
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
|
||||
if exist %WRAPPER_JAR% (
|
||||
if "%MVNW_VERBOSE%" == "true" (
|
||||
echo Found %WRAPPER_JAR%
|
||||
)
|
||||
) else (
|
||||
if not "%MVNW_REPOURL%" == "" (
|
||||
SET WRAPPER_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar"
|
||||
)
|
||||
if "%MVNW_VERBOSE%" == "true" (
|
||||
echo Couldn't find %WRAPPER_JAR%, downloading it ...
|
||||
echo Downloading from: %WRAPPER_URL%
|
||||
)
|
||||
|
||||
powershell -Command "&{"^
|
||||
"$webclient = new-object System.Net.WebClient;"^
|
||||
"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
|
||||
"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
|
||||
"}"^
|
||||
"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%WRAPPER_URL%', '%WRAPPER_JAR%')"^
|
||||
"}"
|
||||
if "%MVNW_VERBOSE%" == "true" (
|
||||
echo Finished downloading %WRAPPER_JAR%
|
||||
)
|
||||
)
|
||||
@REM End of extension
|
||||
|
||||
@REM Provide a "standardized" way to retrieve the CLI args that will
|
||||
@REM work with both Windows and non-Windows executions.
|
||||
set MAVEN_CMD_LINE_ARGS=%*
|
||||
|
||||
%MAVEN_JAVA_EXE% ^
|
||||
%JVM_CONFIG_MAVEN_PROPS% ^
|
||||
%MAVEN_OPTS% ^
|
||||
%MAVEN_DEBUG_OPTS% ^
|
||||
-classpath %WRAPPER_JAR% ^
|
||||
"-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
|
||||
%WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
|
||||
if ERRORLEVEL 1 goto error
|
||||
goto end
|
||||
|
||||
:error
|
||||
set ERROR_CODE=1
|
||||
|
||||
:end
|
||||
@endlocal & set ERROR_CODE=%ERROR_CODE%
|
||||
|
||||
if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
|
||||
@REM check for post script, once with legacy .bat ending and once with .cmd ending
|
||||
if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
|
||||
if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
|
||||
:skipRcPost
|
||||
|
||||
@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
|
||||
if "%MAVEN_BATCH_PAUSE%"=="on" pause
|
||||
|
||||
if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
|
||||
|
||||
cmd /C exit /B %ERROR_CODE%
|
||||
@@ -1,33 +0,0 @@
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<groupId>io.refactoring</groupId>
|
||||
<artifactId>junit5-parameterized-tests</artifactId>
|
||||
<version>1.0.0-SNAPSHOT</version>
|
||||
<properties>
|
||||
<maven.compiler.source>11</maven.compiler.source>
|
||||
<maven.compiler.target>11</maven.compiler.target>
|
||||
|
||||
<junit-jupiter-params.version>5.9.2</junit-jupiter-params.version>
|
||||
<commons-lang3.version>3.12.0</commons-lang3.version>
|
||||
<assertj-core>3.24.1</assertj-core>
|
||||
</properties>
|
||||
|
||||
<dependencies>
|
||||
<!-- https://mvnrepository.com/artifact/org.junit.jupiter/junit-jupiter-params -->
|
||||
<dependency>
|
||||
<groupId>org.junit.jupiter</groupId>
|
||||
<artifactId>junit-jupiter-params</artifactId>
|
||||
<version>${junit-jupiter-params.version}</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
|
||||
<dependency>
|
||||
<groupId>org.apache.commons</groupId>
|
||||
<artifactId>commons-lang3</artifactId>
|
||||
<version>${commons-lang3.version}</version>
|
||||
</dependency>
|
||||
|
||||
</dependencies>
|
||||
|
||||
</project>
|
||||
@@ -1,43 +0,0 @@
|
||||
package source.argument.conversion;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
import static org.junit.jupiter.api.Assertions.assertNotNull;
|
||||
|
||||
import java.time.temporal.ChronoUnit;
|
||||
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.converter.ConvertWith;
|
||||
import org.junit.jupiter.params.provider.ValueSource;
|
||||
|
||||
public class ArgumentConversionTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@ValueSource(ints = { 2, 4 })
|
||||
void checkWideningArgumentConversion(long number) {
|
||||
assertEquals(0, number % 2);
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@ValueSource(strings = "DAYS")
|
||||
void checkImplicitArgumentConversion(ChronoUnit argument) {
|
||||
assertNotNull(argument.name());
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@ValueSource(strings = { "Name1", "Name2" })
|
||||
void checkImplicitFallbackArgumentConversion(Person person) {
|
||||
assertNotNull(person.getName());
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@ValueSource(ints = { 100 })
|
||||
void checkExplicitArgumentConversion(@ConvertWith(StringSimpleArgumentConverter.class) String argument) {
|
||||
assertEquals("100", argument);
|
||||
}
|
||||
}
|
||||
@@ -1,18 +0,0 @@
|
||||
package source.argument.conversion;
|
||||
|
||||
public class Person {
|
||||
|
||||
private String name;
|
||||
|
||||
public Person(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public void setName(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
}
|
||||
@@ -1,13 +0,0 @@
|
||||
package source.argument.conversion;
|
||||
|
||||
import org.junit.jupiter.params.converter.ArgumentConversionException;
|
||||
import org.junit.jupiter.params.converter.SimpleArgumentConverter;
|
||||
|
||||
public class StringSimpleArgumentConverter extends SimpleArgumentConverter {
|
||||
|
||||
@Override
|
||||
protected Object convert(Object source, Class<?> targetType) throws ArgumentConversionException {
|
||||
return String.valueOf(source);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -1,39 +0,0 @@
|
||||
package source.arguments;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
|
||||
import java.util.stream.Stream;
|
||||
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.junit.jupiter.api.extension.ExtensionContext;
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.Arguments;
|
||||
import org.junit.jupiter.params.provider.ArgumentsProvider;
|
||||
import org.junit.jupiter.params.provider.ArgumentsSource;
|
||||
|
||||
public class ArgumentsSourceTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@ArgumentsSource(ExternalArgumentsProvider.class)
|
||||
void checkExternalArgumentsSource(int number, String expected) {
|
||||
assertEquals(StringUtils.equals(expected, "even") ? 0 : 1, number % 2,
|
||||
"Supplied number " + number + " is not an " + expected + " number");
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@ArgumentsSource(NestedArgumentsProvider.class)
|
||||
void checkNestedArgumentsSource(int number, String expected) {
|
||||
assertEquals(StringUtils.equals(expected, "even") ? 0 : 1, number % 2,
|
||||
"Supplied number " + number + " is not an " + expected + " number");
|
||||
}
|
||||
|
||||
static class NestedArgumentsProvider implements ArgumentsProvider {
|
||||
|
||||
@Override
|
||||
public Stream<? extends Arguments> provideArguments(ExtensionContext context) throws Exception {
|
||||
return Stream.of(Arguments.of(2, "even"), Arguments.of(3, "odd"));
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,16 +0,0 @@
|
||||
package source.arguments;
|
||||
|
||||
import java.util.stream.Stream;
|
||||
|
||||
import org.junit.jupiter.api.extension.ExtensionContext;
|
||||
import org.junit.jupiter.params.provider.Arguments;
|
||||
import org.junit.jupiter.params.provider.ArgumentsProvider;
|
||||
|
||||
public class ExternalArgumentsProvider implements ArgumentsProvider {
|
||||
|
||||
@Override
|
||||
public Stream<? extends Arguments> provideArguments(ExtensionContext context) throws Exception {
|
||||
return Stream.of(Arguments.of(2, "even"),
|
||||
Arguments.of(3, "odd"));
|
||||
}
|
||||
}
|
||||
@@ -1,18 +0,0 @@
|
||||
package source.arguments.aggregator;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.aggregator.ArgumentsAccessor;
|
||||
import org.junit.jupiter.params.provider.CsvSource;
|
||||
|
||||
public class ArgumentsAccessorTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@CsvSource({ "John, 20",
|
||||
"Harry, 30" })
|
||||
void checkArgumentsAccessor(ArgumentsAccessor arguments) {
|
||||
Person person = new Person(arguments.getString(0), arguments.getInteger(1));
|
||||
assertTrue(person.getAge() > 19, person.getName() + " is a teenager");
|
||||
}
|
||||
}
|
||||
@@ -1,24 +0,0 @@
|
||||
package source.arguments.aggregator;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.aggregator.AggregateWith;
|
||||
import org.junit.jupiter.params.provider.CsvSource;
|
||||
|
||||
public class ArgumentsAggregatorTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@CsvSource({ "John, 20", "Harry, 30" })
|
||||
void checkArgumentsAggregator(@AggregateWith(PersonArgumentsAggregator.class) Person person) {
|
||||
assertTrue(person.getAge() > 19, person.getName() + " is a teenager");
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@CsvSource({ "John, 20", "Harry, 30" })
|
||||
void checkCustomAggregatorAnnotation(@CsvToPerson Person person) {
|
||||
assertTrue(person.getAge() > 19, person.getName() + " is a teenager");
|
||||
}
|
||||
}
|
||||
@@ -1,15 +0,0 @@
|
||||
package source.arguments.aggregator;
|
||||
|
||||
import java.lang.annotation.ElementType;
|
||||
import java.lang.annotation.Retention;
|
||||
import java.lang.annotation.RetentionPolicy;
|
||||
import java.lang.annotation.Target;
|
||||
|
||||
import org.junit.jupiter.params.aggregator.AggregateWith;
|
||||
|
||||
@Retention(RetentionPolicy.RUNTIME)
|
||||
@Target(ElementType.PARAMETER)
|
||||
@AggregateWith(PersonArgumentsAggregator.class)
|
||||
public @interface CsvToPerson {
|
||||
|
||||
}
|
||||
@@ -1,30 +0,0 @@
|
||||
package source.arguments.aggregator;
|
||||
|
||||
public class Person {
|
||||
|
||||
private String name;
|
||||
|
||||
private int age;
|
||||
|
||||
public Person(String name, int age) {
|
||||
this.name = name;
|
||||
this.age = age;
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public void setName(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
public int getAge() {
|
||||
return age;
|
||||
}
|
||||
|
||||
public void setAge(int age) {
|
||||
this.age = age;
|
||||
}
|
||||
|
||||
}
|
||||
@@ -1,16 +0,0 @@
|
||||
package source.arguments.aggregator;
|
||||
|
||||
import org.junit.jupiter.api.extension.ParameterContext;
|
||||
import org.junit.jupiter.params.aggregator.ArgumentsAccessor;
|
||||
import org.junit.jupiter.params.aggregator.ArgumentsAggregationException;
|
||||
import org.junit.jupiter.params.aggregator.ArgumentsAggregator;
|
||||
|
||||
public class PersonArgumentsAggregator implements ArgumentsAggregator {
|
||||
|
||||
@Override
|
||||
public Object aggregateArguments(ArgumentsAccessor arguments, ParameterContext context)
|
||||
throws ArgumentsAggregationException {
|
||||
return new Person(arguments.getString(0), arguments.getInteger(1));
|
||||
}
|
||||
|
||||
}
|
||||
@@ -1,27 +0,0 @@
|
||||
package source.assertj;
|
||||
|
||||
import java.util.function.Consumer;
|
||||
import java.util.stream.Stream;
|
||||
|
||||
import org.assertj.core.api.Assertions;
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.Arguments;
|
||||
import org.junit.jupiter.params.provider.MethodSource;
|
||||
|
||||
public class AssertJTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@MethodSource("checkNumberArgs")
|
||||
void checkNumber(int number, Consumer<Integer> consumer) {
|
||||
|
||||
consumer.accept(number);
|
||||
}
|
||||
|
||||
static Stream<Arguments> checkNumberArgs() {
|
||||
|
||||
Consumer<Integer> evenConsumer = i -> Assertions.assertThat(i % 2).isZero();
|
||||
Consumer<Integer> oddConsumer = i -> Assertions.assertThat(i % 2).isEqualTo(1);
|
||||
|
||||
return Stream.of(Arguments.of(2, evenConsumer), Arguments.of(3, oddConsumer));
|
||||
}
|
||||
}
|
||||
@@ -1,17 +0,0 @@
|
||||
package source.csv;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.CsvSource;
|
||||
|
||||
public class CsvSourceTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@CsvSource({ "2, even",
|
||||
"3, odd"})
|
||||
void checkCsvSource(int number, String expected) {
|
||||
assertEquals(StringUtils.equals(expected, "even") ? 0 : 1, number % 2);
|
||||
}
|
||||
}
|
||||
@@ -1,27 +0,0 @@
|
||||
package source.csv.file;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.CsvFileSource;
|
||||
|
||||
public class CsvFileSourceTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@CsvFileSource(files = "src/test/resources/csv-file-source.csv", numLinesToSkip = 1)
|
||||
void checkCsvFileSource(int number, String expected) {
|
||||
assertEquals(StringUtils.equals(expected, "even") ? 0 : 1, number % 2);
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@CsvFileSource(files = "src/test/resources/csv-file-source_attributes.csv",
|
||||
delimiterString = "|",
|
||||
lineSeparator = "||",
|
||||
numLinesToSkip = 1)
|
||||
void checkCsvFileSourceAttributes(int number, String expected) {
|
||||
assertEquals(StringUtils.equals(expected, "even") ? 0 : 1, number % 2);
|
||||
}
|
||||
}
|
||||
@@ -1,25 +0,0 @@
|
||||
package source.enumeration;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertNotNull;
|
||||
|
||||
import java.time.temporal.ChronoUnit;
|
||||
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.EnumSource;
|
||||
|
||||
public class EnumSourceTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@EnumSource(ChronoUnit.class)
|
||||
void checkEnumSourceValue(ChronoUnit unit) {
|
||||
assertNotNull(unit);
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@EnumSource(names = { "DAYS", "HOURS" })
|
||||
void checkEnumSourceNames(ChronoUnit unit) {
|
||||
assertNotNull(unit);
|
||||
}
|
||||
}
|
||||
@@ -1,11 +0,0 @@
|
||||
package source.method;
|
||||
|
||||
import java.util.stream.Stream;
|
||||
|
||||
public class ExternalMethodSource {
|
||||
|
||||
static Stream<String> checkExternalMethodSourceArgs() {
|
||||
return Stream.of("a1", "b2");
|
||||
}
|
||||
|
||||
}
|
||||
@@ -1,17 +0,0 @@
|
||||
package source.method;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.MethodSource;
|
||||
|
||||
public class ExternalMethodSourceTest {
|
||||
|
||||
// Note: The test will try to load the external method
|
||||
@ParameterizedTest
|
||||
@MethodSource("source.method.ExternalMethodSource#checkExternalMethodSourceArgs")
|
||||
void checkExternalMethodSource(String word) {
|
||||
assertTrue(StringUtils.isAlphanumeric(word), "Supplied word is not alpha-numeric");
|
||||
}
|
||||
}
|
||||
@@ -1,52 +0,0 @@
|
||||
package source.method;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
import java.util.stream.Stream;
|
||||
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.Arguments;
|
||||
import org.junit.jupiter.params.provider.MethodSource;
|
||||
|
||||
public class MethodSourceTest {
|
||||
|
||||
// Note: The test will try to load the supplied method
|
||||
@ParameterizedTest
|
||||
@MethodSource("checkExplicitMethodSourceArgs")
|
||||
void checkExplicitMethodSource(String word) {
|
||||
assertTrue(StringUtils.isAlphanumeric(word), "Supplied word is not alpha-numeric");
|
||||
}
|
||||
|
||||
static Stream<String> checkExplicitMethodSourceArgs() {
|
||||
return Stream.of("a1", "b2");
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
// Note: The test will search for the source method that matches the test-case
|
||||
// method name
|
||||
@ParameterizedTest
|
||||
@MethodSource
|
||||
void checkImplicitMethodSource(String word) {
|
||||
assertTrue(StringUtils.isAlphanumeric(word), "Supplied word is not alpha-numeric");
|
||||
}
|
||||
|
||||
static Stream<String> checkImplicitMethodSource() {
|
||||
return Stream.of("a1", "b2");
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
// Note: The test will automatically map arguments based on the index
|
||||
@ParameterizedTest
|
||||
@MethodSource
|
||||
void checkMultiArgumentsMethodSource(int number, String expected) {
|
||||
assertEquals(StringUtils.equals(expected, "even") ? 0 : 1, number % 2);
|
||||
}
|
||||
|
||||
static Stream<Arguments> checkMultiArgumentsMethodSource() {
|
||||
return Stream.of(Arguments.of(2, "even"), Arguments.of(3, "odd"));
|
||||
}
|
||||
}
|
||||
@@ -1,44 +0,0 @@
|
||||
package source.null_empty;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.EmptySource;
|
||||
import org.junit.jupiter.params.provider.NullAndEmptySource;
|
||||
import org.junit.jupiter.params.provider.NullSource;
|
||||
import org.junit.jupiter.params.provider.ValueSource;
|
||||
|
||||
public class NullEmptySourceTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@NullSource
|
||||
void checkNull(String value) {
|
||||
assertEquals(null, value);
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@EmptySource
|
||||
void checkEmpty(String value) {
|
||||
assertEquals("", value);
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@NullAndEmptySource
|
||||
void checkNullAndEmpty(String value) {
|
||||
assertTrue(value == null || value.isEmpty());
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@NullAndEmptySource
|
||||
@ValueSource(strings = { " ", " " })
|
||||
void checkNullEmptyAndBlank(String value) {
|
||||
assertTrue(value == null || value.isBlank());
|
||||
}
|
||||
}
|
||||
@@ -1,25 +0,0 @@
|
||||
package source.value;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.ValueSource;
|
||||
|
||||
public class ValueSourceTest {
|
||||
|
||||
@ParameterizedTest
|
||||
@ValueSource(ints = { 2, 4 })
|
||||
void checkEvenNumber(int number) {
|
||||
assertEquals(0, number % 2, "Supplied number is not an even number");
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
@ParameterizedTest
|
||||
@ValueSource(strings = { "a1", "b2" })
|
||||
void checkAlphanumeric(String word) {
|
||||
assertTrue(StringUtils.isAlphanumeric(word), "Supplied word is not alpha-numeric");
|
||||
}
|
||||
}
|
||||
@@ -1,3 +0,0 @@
|
||||
NUMBER, ODD_EVEN
|
||||
2, even
|
||||
3, odd
|
||||
|
@@ -1,3 +0,0 @@
|
||||
|| NUMBER | ODD_EVEN ||
|
||||
|| 2 | even ||
|
||||
|| 3 | odd ||
|
||||
|
@@ -1,40 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0"
|
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<groupId>org.example</groupId>
|
||||
<artifactId>junit5</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
|
||||
<properties>
|
||||
<maven.compiler.source>11</maven.compiler.source>
|
||||
<maven.compiler.target>11</maven.compiler.target>
|
||||
</properties>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>org.junit.jupiter</groupId>
|
||||
<artifactId>junit-jupiter-api</artifactId>
|
||||
<version>5.9.0</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.junit.jupiter</groupId>
|
||||
<artifactId>junit-jupiter-params</artifactId>
|
||||
<version>5.9.0</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.hamcrest</groupId>
|
||||
<artifactId>hamcrest-all</artifactId>
|
||||
<version>1.3</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
</dependencies>
|
||||
|
||||
</project>
|
||||
@@ -1,14 +0,0 @@
|
||||
public class Cat {
|
||||
private String name;
|
||||
|
||||
public Cat(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public Cat() {
|
||||
}
|
||||
}
|
||||
@@ -1,24 +0,0 @@
|
||||
|
||||
public class GoldFish {
|
||||
private String name;
|
||||
private int age;
|
||||
|
||||
public GoldFish(String name, int age) {
|
||||
this.name = name;
|
||||
this.age = age;
|
||||
}
|
||||
public int calculateSpeed() {
|
||||
if (age == 0){
|
||||
throw new RuntimeException("This will fail :((");
|
||||
}
|
||||
return 10 / age;
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public int getAge() {
|
||||
return age;
|
||||
}
|
||||
}
|
||||
@@ -1,71 +0,0 @@
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import static java.util.Arrays.asList;
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.*;
|
||||
|
||||
public class CatTest {
|
||||
@Test
|
||||
public void testMeow() {
|
||||
String catName = "Stilla";
|
||||
int catAge = 3;
|
||||
boolean isNice = false;
|
||||
|
||||
assertThat(catName, equalTo("Stilla"));
|
||||
assertThat(catAge, lessThan(5));
|
||||
assertThat(isNice, is(false));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testCatInstance() {
|
||||
Cat cat = new Cat();
|
||||
|
||||
assertThat(cat, instanceOf(Cat.class));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testSameCatInstance() {
|
||||
Cat cat = new Cat();
|
||||
|
||||
assertThat(cat, sameInstance(cat));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testCollectionContaining() {
|
||||
List<String> catNames = asList("Phibi", "Monica", "Stilla");
|
||||
|
||||
assertThat(catNames, hasItems("Monica", "Phibi"));
|
||||
assertThat(catNames, not(hasItems("Melih")));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testCollectionSize() {
|
||||
List<String> catNames = asList("Phibi", "Monica");
|
||||
|
||||
assertThat(catNames, hasSize(2));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testBean() {
|
||||
Cat cat = new Cat("Mimi");
|
||||
|
||||
assertThat(cat, hasProperty("name", equalTo("Mimi")));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testStringEquality() {
|
||||
String catNameInCaps = "RACHEL";
|
||||
|
||||
assertThat(catNameInCaps, equalToIgnoringCase("rachel"));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testStringContains() {
|
||||
String catName = "Joey The Cute";
|
||||
|
||||
assertThat(catName, containsString("Cute"));
|
||||
}
|
||||
|
||||
}
|
||||
@@ -1,82 +0,0 @@
|
||||
import org.junit.jupiter.api.*;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.*;
|
||||
|
||||
public class DogTest {
|
||||
|
||||
@BeforeAll
|
||||
public static void init() {
|
||||
System.out.println("Doing stuff");
|
||||
}
|
||||
|
||||
@BeforeEach
|
||||
public void doEach() {
|
||||
System.out.println("Hey Doggo");
|
||||
}
|
||||
|
||||
@AfterAll
|
||||
public static void finish() {
|
||||
System.out.println("Finishing stuff");
|
||||
}
|
||||
|
||||
@AfterEach
|
||||
public void doAfterEach() {
|
||||
System.out.println("Bye Doggo");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void barkFailure() {
|
||||
String expectedString = "Meow";
|
||||
assertEquals(expectedString, "Woof");
|
||||
}
|
||||
|
||||
@Disabled("Dog 1 please don't woof")
|
||||
@Test
|
||||
public void testBark1() {
|
||||
String expectedString = "woof1";
|
||||
assertEquals(expectedString, "woof1");
|
||||
System.out.println("WOOF => 1");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testBark2() {
|
||||
String expectedString = "woof2";
|
||||
assertEquals(expectedString, "woof2");
|
||||
System.out.println("WOOF => 2");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testNotBark() {
|
||||
String unexpectedString = "";
|
||||
assertNotEquals(unexpectedString, "woof");
|
||||
System.out.println("Didn't woof!!");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void nullCheck() {
|
||||
Object dog = null;
|
||||
assertNull(dog);
|
||||
System.out.println("Null dog :(");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void nonNullCheck() {
|
||||
String dog = "Max";
|
||||
assertNotNull(dog);
|
||||
System.out.println("Hey I am " + dog);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void trueCheck() {
|
||||
int dogAge = 2;
|
||||
assertTrue(dogAge < 5);
|
||||
System.out.println("I am young :)");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void falseCheck() {
|
||||
int dogAge = 7;
|
||||
assertFalse(dogAge < 5);
|
||||
System.out.println("I am old :(");
|
||||
}
|
||||
}
|
||||
@@ -1,51 +0,0 @@
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.junit.jupiter.params.ParameterizedTest;
|
||||
import org.junit.jupiter.params.provider.Arguments;
|
||||
import org.junit.jupiter.params.provider.MethodSource;
|
||||
import java.util.stream.Stream;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.equalToIgnoringCase;
|
||||
import static org.junit.jupiter.api.Assertions.assertThrows;
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
import static org.junit.jupiter.api.Assumptions.assumeTrue;
|
||||
|
||||
public class GoldFishTest {
|
||||
@Test
|
||||
public void testBooleanAssumption() {
|
||||
GoldFish goldFish = new GoldFish("Windows Jelly", 1);
|
||||
|
||||
assumeTrue(System.getProperty("os.name").contains("Windows"));
|
||||
assertThat(goldFish.getName(), equalToIgnoringCase("Windows Jelly"));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testBooleanAssert() {
|
||||
GoldFish goldFish = new GoldFish("Windows Jelly", 1);
|
||||
|
||||
assert(System.getProperty("os.name").contains("Windows"));
|
||||
assertThat(goldFish.getName(), equalToIgnoringCase("Windows Jelly"));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testException() {
|
||||
GoldFish goldFish = new GoldFish("Goldy", 0);
|
||||
|
||||
RuntimeException exception = assertThrows(RuntimeException.class, goldFish::calculateSpeed);
|
||||
|
||||
assertThat(exception.getMessage(), equalToIgnoringCase("This will fail :(("));
|
||||
}
|
||||
|
||||
@ParameterizedTest
|
||||
@MethodSource("provideFishes")
|
||||
public void parameterizedTest(GoldFish goldFish) {
|
||||
assertTrue(goldFish.getAge() >= 1);
|
||||
}
|
||||
|
||||
private static Stream<Arguments> provideFishes() {
|
||||
return Stream.of(
|
||||
Arguments.of(new GoldFish("Browny", 1)),
|
||||
Arguments.of(new GoldFish("Greeny", 2))
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -1,5 +0,0 @@
|
||||
# Kotlin Coroutine Code Examples
|
||||
|
||||
## Related Blog Articles
|
||||
|
||||
* [Understanding Kotlin Coroutines](understanding-kotlin-coroutines)
|
||||
@@ -1,28 +0,0 @@
|
||||
plugins {
|
||||
id 'org.jetbrains.kotlin.jvm' version '1.6.21'
|
||||
}
|
||||
|
||||
group = 'io.pratik'
|
||||
version = '1.0-SNAPSHOT'
|
||||
|
||||
repositories {
|
||||
mavenCentral()
|
||||
}
|
||||
|
||||
dependencies {
|
||||
implementation 'org.jetbrains.kotlin:kotlin-stdlib'
|
||||
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.6.2'
|
||||
testImplementation 'org.jetbrains.kotlin:kotlin-test'
|
||||
}
|
||||
|
||||
test {
|
||||
useJUnitPlatform()
|
||||
}
|
||||
|
||||
compileKotlin {
|
||||
kotlinOptions.jvmTarget = '1.8'
|
||||
}
|
||||
|
||||
compileTestKotlin {
|
||||
kotlinOptions.jvmTarget = '1.8'
|
||||
}
|
||||
@@ -1 +0,0 @@
|
||||
kotlin.code.style=official
|
||||
BIN
kotlin/coroutines/gradle/wrapper/gradle-wrapper.jar
vendored
BIN
kotlin/coroutines/gradle/wrapper/gradle-wrapper.jar
vendored
Binary file not shown.
@@ -1,5 +0,0 @@
|
||||
distributionBase=GRADLE_USER_HOME
|
||||
distributionPath=wrapper/dists
|
||||
distributionUrl=https\://services.gradle.org/distributions/gradle-7.3.3-bin.zip
|
||||
zipStoreBase=GRADLE_USER_HOME
|
||||
zipStorePath=wrapper/dists
|
||||
234
kotlin/coroutines/gradlew
vendored
234
kotlin/coroutines/gradlew
vendored
@@ -1,234 +0,0 @@
|
||||
#!/bin/sh
|
||||
|
||||
#
|
||||
# Copyright © 2015-2021 the original authors.
|
||||
#
|
||||
# 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
|
||||
#
|
||||
# https://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.
|
||||
#
|
||||
|
||||
##############################################################################
|
||||
#
|
||||
# Gradle start up script for POSIX generated by Gradle.
|
||||
#
|
||||
# Important for running:
|
||||
#
|
||||
# (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
|
||||
# noncompliant, but you have some other compliant shell such as ksh or
|
||||
# bash, then to run this script, type that shell name before the whole
|
||||
# command line, like:
|
||||
#
|
||||
# ksh Gradle
|
||||
#
|
||||
# Busybox and similar reduced shells will NOT work, because this script
|
||||
# requires all of these POSIX shell features:
|
||||
# * functions;
|
||||
# * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
|
||||
# «${var#prefix}», «${var%suffix}», and «$( cmd )»;
|
||||
# * compound commands having a testable exit status, especially «case»;
|
||||
# * various built-in commands including «command», «set», and «ulimit».
|
||||
#
|
||||
# Important for patching:
|
||||
#
|
||||
# (2) This script targets any POSIX shell, so it avoids extensions provided
|
||||
# by Bash, Ksh, etc; in particular arrays are avoided.
|
||||
#
|
||||
# The "traditional" practice of packing multiple parameters into a
|
||||
# space-separated string is a well documented source of bugs and security
|
||||
# problems, so this is (mostly) avoided, by progressively accumulating
|
||||
# options in "$@", and eventually passing that to Java.
|
||||
#
|
||||
# Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
|
||||
# and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
|
||||
# see the in-line comments for details.
|
||||
#
|
||||
# There are tweaks for specific operating systems such as AIX, CygWin,
|
||||
# Darwin, MinGW, and NonStop.
|
||||
#
|
||||
# (3) This script is generated from the Groovy template
|
||||
# https://github.com/gradle/gradle/blob/master/subprojects/plugins/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
|
||||
# within the Gradle project.
|
||||
#
|
||||
# You can find Gradle at https://github.com/gradle/gradle/.
|
||||
#
|
||||
##############################################################################
|
||||
|
||||
# Attempt to set APP_HOME
|
||||
|
||||
# Resolve links: $0 may be a link
|
||||
app_path=$0
|
||||
|
||||
# Need this for daisy-chained symlinks.
|
||||
while
|
||||
APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path
|
||||
[ -h "$app_path" ]
|
||||
do
|
||||
ls=$( ls -ld "$app_path" )
|
||||
link=${ls#*' -> '}
|
||||
case $link in #(
|
||||
/*) app_path=$link ;; #(
|
||||
*) app_path=$APP_HOME$link ;;
|
||||
esac
|
||||
done
|
||||
|
||||
APP_HOME=$( cd "${APP_HOME:-./}" && pwd -P ) || exit
|
||||
|
||||
APP_NAME="Gradle"
|
||||
APP_BASE_NAME=${0##*/}
|
||||
|
||||
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
|
||||
DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
|
||||
|
||||
# Use the maximum available, or set MAX_FD != -1 to use that value.
|
||||
MAX_FD=maximum
|
||||
|
||||
warn () {
|
||||
echo "$*"
|
||||
} >&2
|
||||
|
||||
die () {
|
||||
echo
|
||||
echo "$*"
|
||||
echo
|
||||
exit 1
|
||||
} >&2
|
||||
|
||||
# OS specific support (must be 'true' or 'false').
|
||||
cygwin=false
|
||||
msys=false
|
||||
darwin=false
|
||||
nonstop=false
|
||||
case "$( uname )" in #(
|
||||
CYGWIN* ) cygwin=true ;; #(
|
||||
Darwin* ) darwin=true ;; #(
|
||||
MSYS* | MINGW* ) msys=true ;; #(
|
||||
NONSTOP* ) nonstop=true ;;
|
||||
esac
|
||||
|
||||
CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
|
||||
|
||||
|
||||
# Determine the Java command to use to start the JVM.
|
||||
if [ -n "$JAVA_HOME" ] ; then
|
||||
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
|
||||
# IBM's JDK on AIX uses strange locations for the executables
|
||||
JAVACMD=$JAVA_HOME/jre/sh/java
|
||||
else
|
||||
JAVACMD=$JAVA_HOME/bin/java
|
||||
fi
|
||||
if [ ! -x "$JAVACMD" ] ; then
|
||||
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
|
||||
|
||||
Please set the JAVA_HOME variable in your environment to match the
|
||||
location of your Java installation."
|
||||
fi
|
||||
else
|
||||
JAVACMD=java
|
||||
which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
|
||||
|
||||
Please set the JAVA_HOME variable in your environment to match the
|
||||
location of your Java installation."
|
||||
fi
|
||||
|
||||
# Increase the maximum file descriptors if we can.
|
||||
if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
|
||||
case $MAX_FD in #(
|
||||
max*)
|
||||
MAX_FD=$( ulimit -H -n ) ||
|
||||
warn "Could not query maximum file descriptor limit"
|
||||
esac
|
||||
case $MAX_FD in #(
|
||||
'' | soft) :;; #(
|
||||
*)
|
||||
ulimit -n "$MAX_FD" ||
|
||||
warn "Could not set maximum file descriptor limit to $MAX_FD"
|
||||
esac
|
||||
fi
|
||||
|
||||
# Collect all arguments for the java command, stacking in reverse order:
|
||||
# * args from the command line
|
||||
# * the main class name
|
||||
# * -classpath
|
||||
# * -D...appname settings
|
||||
# * --module-path (only if needed)
|
||||
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
|
||||
|
||||
# For Cygwin or MSYS, switch paths to Windows format before running java
|
||||
if "$cygwin" || "$msys" ; then
|
||||
APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
|
||||
CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
|
||||
|
||||
JAVACMD=$( cygpath --unix "$JAVACMD" )
|
||||
|
||||
# Now convert the arguments - kludge to limit ourselves to /bin/sh
|
||||
for arg do
|
||||
if
|
||||
case $arg in #(
|
||||
-*) false ;; # don't mess with options #(
|
||||
/?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath
|
||||
[ -e "$t" ] ;; #(
|
||||
*) false ;;
|
||||
esac
|
||||
then
|
||||
arg=$( cygpath --path --ignore --mixed "$arg" )
|
||||
fi
|
||||
# Roll the args list around exactly as many times as the number of
|
||||
# args, so each arg winds up back in the position where it started, but
|
||||
# possibly modified.
|
||||
#
|
||||
# NB: a `for` loop captures its iteration list before it begins, so
|
||||
# changing the positional parameters here affects neither the number of
|
||||
# iterations, nor the values presented in `arg`.
|
||||
shift # remove old arg
|
||||
set -- "$@" "$arg" # push replacement arg
|
||||
done
|
||||
fi
|
||||
|
||||
# Collect all arguments for the java command;
|
||||
# * $DEFAULT_JVM_OPTS, $JAVA_OPTS, and $GRADLE_OPTS can contain fragments of
|
||||
# shell script including quotes and variable substitutions, so put them in
|
||||
# double quotes to make sure that they get re-expanded; and
|
||||
# * put everything else in single quotes, so that it's not re-expanded.
|
||||
|
||||
set -- \
|
||||
"-Dorg.gradle.appname=$APP_BASE_NAME" \
|
||||
-classpath "$CLASSPATH" \
|
||||
org.gradle.wrapper.GradleWrapperMain \
|
||||
"$@"
|
||||
|
||||
# Use "xargs" to parse quoted args.
|
||||
#
|
||||
# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
|
||||
#
|
||||
# In Bash we could simply go:
|
||||
#
|
||||
# readarray ARGS < <( xargs -n1 <<<"$var" ) &&
|
||||
# set -- "${ARGS[@]}" "$@"
|
||||
#
|
||||
# but POSIX shell has neither arrays nor command substitution, so instead we
|
||||
# post-process each arg (as a line of input to sed) to backslash-escape any
|
||||
# character that might be a shell metacharacter, then use eval to reverse
|
||||
# that process (while maintaining the separation between arguments), and wrap
|
||||
# the whole thing up as a single "set" statement.
|
||||
#
|
||||
# This will of course break if any of these variables contains a newline or
|
||||
# an unmatched quote.
|
||||
#
|
||||
|
||||
eval "set -- $(
|
||||
printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
|
||||
xargs -n1 |
|
||||
sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
|
||||
tr '\n' ' '
|
||||
)" '"$@"'
|
||||
|
||||
exec "$JAVACMD" "$@"
|
||||
89
kotlin/coroutines/gradlew.bat
vendored
89
kotlin/coroutines/gradlew.bat
vendored
@@ -1,89 +0,0 @@
|
||||
@rem
|
||||
@rem Copyright 2015 the original author or authors.
|
||||
@rem
|
||||
@rem Licensed under the Apache License, Version 2.0 (the "License");
|
||||
@rem you may not use this file except in compliance with the License.
|
||||
@rem You may obtain a copy of the License at
|
||||
@rem
|
||||
@rem https://www.apache.org/licenses/LICENSE-2.0
|
||||
@rem
|
||||
@rem Unless required by applicable law or agreed to in writing, software
|
||||
@rem distributed under the License is distributed on an "AS IS" BASIS,
|
||||
@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
@rem See the License for the specific language governing permissions and
|
||||
@rem limitations under the License.
|
||||
@rem
|
||||
|
||||
@if "%DEBUG%" == "" @echo off
|
||||
@rem ##########################################################################
|
||||
@rem
|
||||
@rem Gradle startup script for Windows
|
||||
@rem
|
||||
@rem ##########################################################################
|
||||
|
||||
@rem Set local scope for the variables with windows NT shell
|
||||
if "%OS%"=="Windows_NT" setlocal
|
||||
|
||||
set DIRNAME=%~dp0
|
||||
if "%DIRNAME%" == "" set DIRNAME=.
|
||||
set APP_BASE_NAME=%~n0
|
||||
set APP_HOME=%DIRNAME%
|
||||
|
||||
@rem Resolve any "." and ".." in APP_HOME to make it shorter.
|
||||
for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
|
||||
|
||||
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
|
||||
set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
|
||||
|
||||
@rem Find java.exe
|
||||
if defined JAVA_HOME goto findJavaFromJavaHome
|
||||
|
||||
set JAVA_EXE=java.exe
|
||||
%JAVA_EXE% -version >NUL 2>&1
|
||||
if "%ERRORLEVEL%" == "0" goto execute
|
||||
|
||||
echo.
|
||||
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
|
||||
echo.
|
||||
echo Please set the JAVA_HOME variable in your environment to match the
|
||||
echo location of your Java installation.
|
||||
|
||||
goto fail
|
||||
|
||||
:findJavaFromJavaHome
|
||||
set JAVA_HOME=%JAVA_HOME:"=%
|
||||
set JAVA_EXE=%JAVA_HOME%/bin/java.exe
|
||||
|
||||
if exist "%JAVA_EXE%" goto execute
|
||||
|
||||
echo.
|
||||
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
|
||||
echo.
|
||||
echo Please set the JAVA_HOME variable in your environment to match the
|
||||
echo location of your Java installation.
|
||||
|
||||
goto fail
|
||||
|
||||
:execute
|
||||
@rem Setup the command line
|
||||
|
||||
set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
|
||||
|
||||
|
||||
@rem Execute Gradle
|
||||
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
|
||||
|
||||
:end
|
||||
@rem End local scope for the variables with windows NT shell
|
||||
if "%ERRORLEVEL%"=="0" goto mainEnd
|
||||
|
||||
:fail
|
||||
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
|
||||
rem the _cmd.exe /c_ return code!
|
||||
if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
|
||||
exit /b 1
|
||||
|
||||
:mainEnd
|
||||
if "%OS%"=="Windows_NT" endlocal
|
||||
|
||||
:omega
|
||||
@@ -1,3 +0,0 @@
|
||||
|
||||
rootProject.name = 'CoroutineApp'
|
||||
|
||||
@@ -1,23 +0,0 @@
|
||||
package io.pratik
|
||||
|
||||
import kotlinx.coroutines.*
|
||||
import java.util.UUID
|
||||
|
||||
fun main() = runBlocking{
|
||||
println("program runs...: ${Thread.currentThread().name}")
|
||||
|
||||
val taskDeferred = async {
|
||||
generateUniqueID()
|
||||
}
|
||||
val taskResult = taskDeferred.await()
|
||||
|
||||
println("program run ends...: ${taskResult} ${Thread.currentThread().name}")
|
||||
}
|
||||
|
||||
suspend fun generateUniqueID(): String{
|
||||
println("executing generateUniqueID on...: ${Thread.currentThread().name}")
|
||||
delay(1000)
|
||||
println("generateUniqueID ends on thread ...: ${Thread.currentThread().name}")
|
||||
|
||||
return UUID.randomUUID().toString()
|
||||
}
|
||||
@@ -1,32 +0,0 @@
|
||||
package io.pratik
|
||||
|
||||
import kotlinx.coroutines.*
|
||||
import java.io.File
|
||||
|
||||
fun main() = runBlocking{
|
||||
println("program runs...: ${Thread.currentThread().name}")
|
||||
|
||||
val job:Job = launch {
|
||||
val files = File ("/Users/10680240/Downloads/").listFiles()
|
||||
var loop = 0
|
||||
|
||||
while (loop < files.size-1 ) {
|
||||
if(isActive) {
|
||||
readFile(files.get(++loop))
|
||||
}
|
||||
}
|
||||
}
|
||||
delay(1500)
|
||||
job.cancelAndJoin()
|
||||
|
||||
println("program run ends...: ${Thread.currentThread().name}")
|
||||
}
|
||||
|
||||
suspend fun readFile(file: File) {
|
||||
println("reading file ${file.name}")
|
||||
if (file.isFile) {
|
||||
// process file
|
||||
}
|
||||
delay(100)
|
||||
}
|
||||
|
||||
@@ -1,33 +0,0 @@
|
||||
package io.pratik
|
||||
|
||||
import kotlinx.coroutines.*
|
||||
import java.io.File
|
||||
|
||||
|
||||
fun main() = runBlocking{
|
||||
try {
|
||||
val job1 = launch {
|
||||
repeat(20){
|
||||
println("processing job 1: ${Thread.currentThread().name}")
|
||||
yield()
|
||||
}
|
||||
}
|
||||
|
||||
val job2 = launch {
|
||||
repeat(20){
|
||||
println("processing job 2: ${Thread.currentThread().name}")
|
||||
yield()
|
||||
}
|
||||
}
|
||||
|
||||
job1.join()
|
||||
job2.join()
|
||||
|
||||
} catch (e: CancellationException) {
|
||||
// clean up code
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -1,39 +0,0 @@
|
||||
package io.pratik
|
||||
|
||||
import kotlinx.coroutines.*
|
||||
import kotlin.coroutines.ContinuationInterceptor
|
||||
|
||||
fun main() = runBlocking {
|
||||
println(coroutineContext)
|
||||
launch {
|
||||
println(
|
||||
"launch default: running in thread ${Thread.currentThread().name} ${coroutineContext[ContinuationInterceptor]}")
|
||||
longTask()
|
||||
}
|
||||
|
||||
/* launch(Dispatchers.Unconfined) { // not confined -- will work with main thread
|
||||
println("Unconfined : running in thread ${Thread.currentThread().name}")
|
||||
longTask()
|
||||
}*/
|
||||
/*repeat(1000) {
|
||||
val dispatcher = Dispatchers.Default.limitedParallelism(3)
|
||||
launch(dispatcher) {
|
||||
// launch(Dispatchers.Default) { // will get dispatched to DefaultDispatcher
|
||||
println("Default : running in thread ${Thread.currentThread().name}")
|
||||
longTask()
|
||||
}
|
||||
}*/
|
||||
/* launch(newSingleThreadContext("MyThread")) { // will get its own new thread
|
||||
println("newSingleThreadContext: running in thread ${Thread.currentThread().name}")
|
||||
longTask()
|
||||
}*/
|
||||
println("completed tasks")
|
||||
}
|
||||
|
||||
|
||||
suspend fun longTask(){
|
||||
println("executing longTask on...: ${Thread.currentThread().name}")
|
||||
delay(1000)
|
||||
println("longTask ends on thread ...: ${Thread.currentThread().name}")
|
||||
}
|
||||
|
||||
@@ -1,34 +0,0 @@
|
||||
package io.pratik
|
||||
|
||||
import kotlinx.coroutines.coroutineScope
|
||||
import kotlinx.coroutines.delay
|
||||
import kotlinx.coroutines.launch
|
||||
import kotlinx.coroutines.runBlocking
|
||||
|
||||
fun main() = runBlocking {
|
||||
executeTasks()
|
||||
println("completed all tasks")
|
||||
}
|
||||
|
||||
// Concurrently executes both sections
|
||||
suspend fun executeTasks() = coroutineScope { // this: CoroutineScope
|
||||
launch {
|
||||
longRunningTask1()
|
||||
}
|
||||
launch {
|
||||
longRunningTask2()
|
||||
}
|
||||
println("completed task1 and task2")
|
||||
}
|
||||
|
||||
suspend fun longRunningTask1(){
|
||||
println("executing longRunningTask1 on...: ${Thread.currentThread().name}")
|
||||
delay(1000)
|
||||
println("longRunningTask1 ends on thread ...: ${Thread.currentThread().name}")
|
||||
}
|
||||
|
||||
suspend fun longRunningTask2(){
|
||||
println("executing longRunningTask2 on...: ${Thread.currentThread().name}")
|
||||
delay(1000)
|
||||
println("longRunningTask2 ends on thread ...: ${Thread.currentThread().name}")
|
||||
}
|
||||
@@ -1,22 +0,0 @@
|
||||
package io.pratik
|
||||
|
||||
import kotlinx.coroutines.*
|
||||
import kotlin.coroutines.EmptyCoroutineContext
|
||||
|
||||
fun main() = runBlocking{
|
||||
println("My program runs...: ${Thread.currentThread().name}")
|
||||
|
||||
val job:Job = launch (EmptyCoroutineContext, CoroutineStart.DEFAULT){
|
||||
longRunningTaskSuspended()
|
||||
}
|
||||
|
||||
job.join()
|
||||
|
||||
println("My program run ends...: ${Thread.currentThread().name}")
|
||||
}
|
||||
|
||||
suspend fun longRunningTaskSuspended(){
|
||||
println("executing longRunningTask on...: ${Thread.currentThread().name}")
|
||||
delay(1000)
|
||||
println("longRunningTask ends on thread ...: ${Thread.currentThread().name}")
|
||||
}
|
||||
@@ -1,26 +0,0 @@
|
||||
package io.pratik
|
||||
|
||||
import kotlinx.coroutines.GlobalScope
|
||||
import kotlinx.coroutines.delay
|
||||
import kotlinx.coroutines.launch
|
||||
import kotlinx.coroutines.runBlocking
|
||||
import kotlin.concurrent.thread
|
||||
|
||||
|
||||
fun main() = runBlocking{
|
||||
println("My program runs...: ${Thread.currentThread().name}")
|
||||
|
||||
launch {
|
||||
longRunningTask()
|
||||
}
|
||||
|
||||
println("My program run ends...: " +
|
||||
"${Thread.currentThread().name}")
|
||||
}
|
||||
|
||||
suspend fun longRunningTask(){
|
||||
println("executing longRunningTask on...: ${Thread.currentThread().name}")
|
||||
delay(1000)
|
||||
println("longRunningTask ends on thread ...: ${Thread.currentThread().name}")
|
||||
}
|
||||
|
||||
@@ -1,36 +0,0 @@
|
||||
package io.pratik
|
||||
|
||||
import kotlinx.coroutines.*
|
||||
import java.time.Instant
|
||||
import kotlin.concurrent.thread
|
||||
|
||||
|
||||
fun main() = runBlocking{
|
||||
println("${Instant.now()}: My program runs...: ${Thread.currentThread().name}")
|
||||
val productId = findProduct()
|
||||
|
||||
launch (Dispatchers.Unconfined) {
|
||||
val price = fetchPrice(productId)
|
||||
}
|
||||
updateProduct()
|
||||
println("${Instant.now()}: My program run ends...: " +
|
||||
"${Thread.currentThread().name}")
|
||||
}
|
||||
|
||||
suspend fun fetchPrice(productId: String) : Double{
|
||||
println("${Instant.now()}: fetchPrice starts on...: ${Thread.currentThread().name} ")
|
||||
delay(2000)
|
||||
println("${Instant.now()}: fetchPrice ends on...: ${Thread.currentThread().name} ")
|
||||
return 234.5
|
||||
}
|
||||
|
||||
fun findProduct() : String{
|
||||
println("${Instant.now()}: findProduct on...: ${Thread.currentThread().name}")
|
||||
return "P12333"
|
||||
}
|
||||
|
||||
fun updateProduct() : String{
|
||||
println("${Instant.now()}: updateProduct on...: ${Thread.currentThread().name}")
|
||||
return "Product updated"
|
||||
}
|
||||
|
||||
@@ -1 +0,0 @@
|
||||
### NBuild Awesome CRUD APIs Using Apollo Server(Graphql), MongoDB and Node.Js Code Example
|
||||
@@ -1,28 +0,0 @@
|
||||
const { ApolloServer } = require("@apollo/server");
|
||||
const { startStandaloneServer } = require("@apollo/server/standalone");
|
||||
const mongoose = require("mongoose");
|
||||
const { resolvers } = require("./resolvers.js");
|
||||
const { typeDefs } = require("./models/typeDefs.js");
|
||||
|
||||
const MONGO_URI = "mongodb://localhost:27017/student-register";
|
||||
|
||||
// Database connection
|
||||
mongoose
|
||||
.connect(MONGO_URI, {
|
||||
useNewUrlParser: true,
|
||||
useUnifiedTopology: true,
|
||||
})
|
||||
.then(() => {
|
||||
console.log(`Db Connected`);
|
||||
})
|
||||
.catch(err => {
|
||||
console.log(err.message);
|
||||
});
|
||||
|
||||
const server = new ApolloServer({ typeDefs, resolvers });
|
||||
|
||||
startStandaloneServer(server, {
|
||||
listen: { port: 4000 },
|
||||
}).then(({ url }) => {
|
||||
console.log(`Server ready at ${url}`);
|
||||
});
|
||||
@@ -1,9 +0,0 @@
|
||||
const mongoose = require("mongoose");
|
||||
|
||||
const Student = mongoose.model("Student", {
|
||||
firstName: String,
|
||||
lastName: String,
|
||||
age: Number,
|
||||
});
|
||||
|
||||
module.exports = { Student };
|
||||
@@ -1,23 +0,0 @@
|
||||
const gql = require("graphql-tag");
|
||||
|
||||
const typeDefs = gql`
|
||||
type Query {
|
||||
hello: String
|
||||
welcome(name: String): String
|
||||
students: [Student] #return array of students
|
||||
student(id: ID): Student #return student by id
|
||||
}
|
||||
type Student {
|
||||
id: ID
|
||||
firstName: String
|
||||
lastName: String
|
||||
age: Int
|
||||
}
|
||||
type Mutation {
|
||||
create(firstName: String, lastName: String, age: Int): Student
|
||||
update(id: ID, firstName: String, lastName: String, age: Int): Student
|
||||
delete(id: ID): Student
|
||||
}
|
||||
`;
|
||||
|
||||
module.exports = { typeDefs };
|
||||
@@ -1,20 +0,0 @@
|
||||
{
|
||||
"name": "graphql",
|
||||
"version": "1.0.0",
|
||||
"description": "",
|
||||
"main": "index.js",
|
||||
"scripts": {
|
||||
"test": "echo \"Error: no test specified\" && exit 1",
|
||||
"start": "node index.js",
|
||||
"dev": "nodemon index.js"
|
||||
},
|
||||
"keywords": [],
|
||||
"author": "",
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
"@apollo/server": "^4.4.1",
|
||||
"graphql": "^16.6.0",
|
||||
"graphql-tag": "^2.12.6",
|
||||
"mongoose": "^7.0.1"
|
||||
}
|
||||
}
|
||||
@@ -1,41 +0,0 @@
|
||||
const { Student } = require("./models/Student.js");
|
||||
|
||||
// GraphQL Resolvers
|
||||
const resolvers = {
|
||||
Query: {
|
||||
hello: () => "Hello from Reflectoring Blog",
|
||||
welcome: (parent, args) => `Hello ${args.name}`,
|
||||
students: async () => await Student.find({}), // return array of students
|
||||
student: async (parent, args) => await Student.findById(args.id), // return student by id
|
||||
},
|
||||
Mutation: {
|
||||
create: async (parent, args) => {
|
||||
const { firstName, lastName, age } = args;
|
||||
const newStudent = new Student({
|
||||
firstName,
|
||||
lastName,
|
||||
age,
|
||||
});
|
||||
await newStudent.save();
|
||||
return newStudent;
|
||||
},
|
||||
update: async (parent, args) => {
|
||||
const { id } = args;
|
||||
const updatedStudent = await Student.findByIdAndUpdate(id, args);
|
||||
if (!updatedStudent) {
|
||||
throw new Error(`Student with ID ${id} not found`);
|
||||
}
|
||||
return updatedStudent;
|
||||
},
|
||||
delete: async (parent, args) => {
|
||||
const { id } = args;
|
||||
const deletedStudent = await Student.findByIdAndDelete(id);
|
||||
if (!deletedStudent) {
|
||||
throw new Error(`Student with ID ${id} not found`);
|
||||
}
|
||||
return deletedStudent;
|
||||
},
|
||||
},
|
||||
};
|
||||
|
||||
module.exports = { resolvers };
|
||||
@@ -1,6 +0,0 @@
|
||||
2022-09-01T23:52:45.356Z, 6.6314544677734375, 11%
|
||||
2022-09-01T23:53:00.489Z, 6.702445983886719, 13%
|
||||
2022-09-01T23:53:15.609Z, 6.74859619140625, 14%
|
||||
2022-09-01T23:53:30.727Z, 6.795112609863281, 11%
|
||||
2022-09-01T23:53:45.817Z, 6.841529846191406, 11%
|
||||
2022-09-01T23:54:00.899Z, 6.8905181884765625, 11%
|
||||
|
@@ -1,20 +0,0 @@
|
||||
// Scheduling a simple task with node cron.
|
||||
|
||||
const cron = require("node-cron");
|
||||
const express = require("express");
|
||||
|
||||
const app = express();
|
||||
|
||||
cron.schedule("*/15 * * * * *", function () {
|
||||
console.log("---------------------");
|
||||
console.log("running a task every 10 second");
|
||||
//replace with any task
|
||||
});
|
||||
|
||||
app.listen(3000);
|
||||
|
||||
/*
|
||||
* Run the script: `node example1.js`
|
||||
* To log on application
|
||||
* at scheduled time
|
||||
*/
|
||||
@@ -1,48 +0,0 @@
|
||||
const express = require("express");
|
||||
const cron = require("node-cron");
|
||||
const nodemailer = require("nodemailer");
|
||||
app = express();
|
||||
|
||||
//send email after 1 minute
|
||||
cron.schedule("1 * * * *", function () {
|
||||
mailService();
|
||||
});
|
||||
|
||||
function mailService() {
|
||||
let mailTransporter = nodemailer.createTransport({
|
||||
service: "gmail",
|
||||
auth: {
|
||||
user: "<your-email>@gmail.com",
|
||||
// use generated app password for gmail
|
||||
pass: "***********",
|
||||
},
|
||||
});
|
||||
|
||||
// setting credentials
|
||||
let mailDetails = {
|
||||
from: "<your-email>@gmail.com",
|
||||
to: "<user-email>@gmail.com",
|
||||
subject: "Test Mail using Cron Job",
|
||||
text: "Node.js Cron Job Email Demo Test from Reflectoring Blog",
|
||||
};
|
||||
|
||||
// sending email
|
||||
mailTransporter.sendMail(mailDetails, function (err, data) {
|
||||
if (err) {
|
||||
console.log("error occurred", err.message);
|
||||
} else {
|
||||
console.log("---------------------");
|
||||
console.log("email sent successfully");
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
app.listen(3000, () => {
|
||||
console.log("application listening.....");
|
||||
});
|
||||
|
||||
/*
|
||||
* Run the script: `node example2.js`
|
||||
* To send E-mail
|
||||
* at scheduled time
|
||||
*/
|
||||
@@ -1,36 +0,0 @@
|
||||
// Writing to a log file
|
||||
|
||||
// Importing required packages
|
||||
const process = require("process");
|
||||
const fs = require("fs");
|
||||
const os = require("os");
|
||||
const cron = require("node-cron");
|
||||
const express = require("express");
|
||||
|
||||
app = express();
|
||||
|
||||
// setting a cron job for every 15 seconds
|
||||
cron.schedule("*/15 * * * * *", function () {
|
||||
let heap = process.memoryUsage().heapUsed / 1024 / 1024;
|
||||
let date = new Date().toISOString();
|
||||
const freeMemory = Math.round((os.freemem() * 100) / os.totalmem()) + "%";
|
||||
|
||||
// date | heap used | free memory
|
||||
let csv = `${date}, ${heap}, ${freeMemory}\n`;
|
||||
|
||||
// storing log In .csv file
|
||||
fs.appendFile("demo.csv", csv, function (err) {
|
||||
if (err) throw err;
|
||||
console.log("server details logged!");
|
||||
});
|
||||
});
|
||||
|
||||
app.listen(3000, () => {
|
||||
console.log("application listening.....");
|
||||
});
|
||||
|
||||
/*
|
||||
* Run the script: `node example3.js`
|
||||
* To generate logstatus.txt file
|
||||
* at scheduled time
|
||||
*/
|
||||
@@ -1,26 +0,0 @@
|
||||
// Deleting / Refreshing A log file.
|
||||
const express = require("express");
|
||||
const cron = require("node-cron");
|
||||
const fs = require("fs");
|
||||
|
||||
app = express();
|
||||
|
||||
// remove the demo.csv file every twenty-first day of the month.
|
||||
cron.schedule("0 0 25 * *", function () {
|
||||
console.log("---------------------");
|
||||
console.log("deleting logged status");
|
||||
fs.unlink("./demo.csv", err => {
|
||||
if (err) throw err;
|
||||
console.log("deleted successfully");
|
||||
});
|
||||
});
|
||||
|
||||
app.listen(3000, () => {
|
||||
console.log("application listening.....");
|
||||
});
|
||||
|
||||
/*
|
||||
* Run the script: `node example4.js`
|
||||
* To delete demo.csv file
|
||||
* at scheduled time
|
||||
*/
|
||||
@@ -1,16 +0,0 @@
|
||||
{
|
||||
"name": "new-folder-(3)",
|
||||
"version": "1.0.0",
|
||||
"description": "",
|
||||
"main": "index.js",
|
||||
"scripts": {
|
||||
"start": "nodemon index.js"
|
||||
},
|
||||
"keywords": [],
|
||||
"author": "",
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
"node-cron": "^3.0.2",
|
||||
"node-mailer": "^0.1.1"
|
||||
}
|
||||
}
|
||||
@@ -1,12 +0,0 @@
|
||||
# Node.js Logging: Novice to Expert
|
||||
|
||||
### Run `npm install` to get started
|
||||
|
||||
To use new Winston Feature
|
||||
- Switch logger import in logging-via-winston/app.js
|
||||
`const logger = require("./logger");`
|
||||
|
||||
- Example:
|
||||
|
||||
To Use winston prettyPrint switch logger import to:
|
||||
`const logger = require("./logger-prettyPrint.js");`
|
||||
@@ -1,21 +0,0 @@
|
||||
const express = require("express");
|
||||
const app = express();
|
||||
|
||||
app.get("/", (req, res, next) => {
|
||||
console.log("debug", "Hello, Winston!");
|
||||
console.log("The is the home '/' route.");
|
||||
res.status(200).send("Logging Hello World..");
|
||||
});
|
||||
|
||||
app.get("/event", (req, res, next) => {
|
||||
try {
|
||||
throw new Error("Not User!");
|
||||
} catch (error) {
|
||||
console.error("Events Error: Unauthenticated user");
|
||||
res.status(500).send("Error!");
|
||||
}
|
||||
});
|
||||
|
||||
app.listen(3000, () => {
|
||||
console.log("Server Listenning On Port 3000");
|
||||
});
|
||||
@@ -1,22 +0,0 @@
|
||||
const express = require("express");
|
||||
const logger = require("./logger");
|
||||
const app = express();
|
||||
|
||||
app.get("/", (req, res, next) => {
|
||||
logger.log("debug", "Hello, Winston!");
|
||||
logger.debug("The is the home '/' route.");
|
||||
res.status(200).send("Logging Hello World..");
|
||||
});
|
||||
|
||||
app.get("/event", (req, res, next) => {
|
||||
try {
|
||||
throw new Error("Not User!");
|
||||
} catch (error) {
|
||||
logger.error("Events Error: Unauthenticated user");
|
||||
res.status(500).send("Error!");
|
||||
}
|
||||
});
|
||||
|
||||
app.listen(3000, () => {
|
||||
logger.info("Server Listenning On Port 3000");
|
||||
});
|
||||
@@ -1,21 +0,0 @@
|
||||
const { format, createLogger, transports } = require("winston");
|
||||
const { combine, label, json } = format;
|
||||
require("winston-daily-rotate-file");
|
||||
|
||||
//Label
|
||||
const CATEGORY = "Log Rotation";
|
||||
|
||||
//DailyRotateFile func()
|
||||
const fileRotateTransport = new transports.DailyRotateFile({
|
||||
filename: "logs/rotate-%DATE%.log",
|
||||
datePattern: "YYYY-MM-DD",
|
||||
maxFiles: "14d",
|
||||
});
|
||||
|
||||
const logger = createLogger({
|
||||
level: "debug",
|
||||
format: combine(label({ label: CATEGORY }), json()),
|
||||
transports: [fileRotateTransport, new transports.Console()],
|
||||
});
|
||||
|
||||
module.exports = logger;
|
||||
@@ -1,26 +0,0 @@
|
||||
const { format, createLogger, transports } = require("winston");
|
||||
const { combine, timestamp, label, printf, prettyPrint } = format;
|
||||
const CATEGORY = "winston custom format";
|
||||
|
||||
const logger = createLogger({
|
||||
level: "debug",
|
||||
format: combine(
|
||||
label({ label: CATEGORY }),
|
||||
timestamp({
|
||||
format: "MMM-DD-YYYY HH:mm:ss",
|
||||
}),
|
||||
prettyPrint()
|
||||
),
|
||||
transports: [
|
||||
new transports.File({
|
||||
filename: "logs/example.log",
|
||||
}),
|
||||
new transports.File({
|
||||
level: "error",
|
||||
filename: "logs/error.log",
|
||||
}),
|
||||
new transports.Console(),
|
||||
],
|
||||
});
|
||||
|
||||
module.exports = logger;
|
||||
@@ -1,17 +0,0 @@
|
||||
const { format, createLogger, transports } = require("winston");
|
||||
const { combine, timestamp, label, printf, prettyPrint } = format;
|
||||
const CATEGORY = "winston custom format";
|
||||
|
||||
const logger = createLogger({
|
||||
level: "debug",
|
||||
format: combine(
|
||||
label({ label: CATEGORY }),
|
||||
timestamp({
|
||||
format: "MMM-DD-YYYY HH:mm:ss",
|
||||
}),
|
||||
prettyPrint()
|
||||
),
|
||||
transports: [new transports.Console()],
|
||||
});
|
||||
|
||||
module.exports = logger;
|
||||
@@ -1,17 +0,0 @@
|
||||
const { format, createLogger, transports } = require("winston");
|
||||
|
||||
const { combine, timestamp, label, printf } = format;
|
||||
const CATEGORY = "winston custom format";
|
||||
|
||||
//Using the printf format.
|
||||
const customFormat = printf(({ level, message, label, timestamp }) => {
|
||||
return `${timestamp} [${label}] ${level}: ${message}`;
|
||||
});
|
||||
|
||||
const logger = createLogger({
|
||||
level: "debug",
|
||||
format: combine(label({ label: CATEGORY }), timestamp(), customFormat),
|
||||
transports: [new transports.Console()],
|
||||
});
|
||||
|
||||
module.exports = logger;
|
||||
@@ -1,16 +0,0 @@
|
||||
const { createLogger, transports, format } = require("winston");
|
||||
|
||||
const logger = createLogger({
|
||||
level: "debug",
|
||||
format: format.json(),
|
||||
//logger method...
|
||||
transports: [
|
||||
//new transports:
|
||||
new transports.File({
|
||||
filename: "logs/example.log",
|
||||
}),
|
||||
],
|
||||
//...
|
||||
});
|
||||
|
||||
module.exports = logger;
|
||||
@@ -1,9 +0,0 @@
|
||||
const { createLogger, transports, format } = require("winston");
|
||||
|
||||
const logger = createLogger({
|
||||
level: "debug",
|
||||
format: format.json(),
|
||||
transports: [new transports.Console()],
|
||||
});
|
||||
|
||||
module.exports = logger;
|
||||
@@ -1,17 +0,0 @@
|
||||
{
|
||||
"name": "logging-file",
|
||||
"version": "1.0.0",
|
||||
"description": "",
|
||||
"main": "index.js",
|
||||
"scripts": {
|
||||
"test": "echo \"Error: no test specified\" && exit 1"
|
||||
},
|
||||
"keywords": [],
|
||||
"author": "",
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
"express": "^4.18.1",
|
||||
"winston": "^3.8.1",
|
||||
"winston-daily-rotate-file": "^4.7.1"
|
||||
}
|
||||
}
|
||||
23
nodejs/node-csv-importer/client/.gitignore
vendored
23
nodejs/node-csv-importer/client/.gitignore
vendored
@@ -1,23 +0,0 @@
|
||||
# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
|
||||
|
||||
# dependencies
|
||||
/node_modules
|
||||
/.pnp
|
||||
.pnp.js
|
||||
|
||||
# testing
|
||||
/coverage
|
||||
|
||||
# production
|
||||
/build
|
||||
|
||||
# misc
|
||||
.DS_Store
|
||||
.env.local
|
||||
.env.development.local
|
||||
.env.test.local
|
||||
.env.production.local
|
||||
|
||||
npm-debug.log*
|
||||
yarn-debug.log*
|
||||
yarn-error.log*
|
||||
@@ -1,70 +0,0 @@
|
||||
# Getting Started with Create React App
|
||||
|
||||
This project was bootstrapped with [Create React App](https://github.com/facebook/create-react-app).
|
||||
|
||||
## Available Scripts
|
||||
|
||||
In the project directory, you can run:
|
||||
|
||||
### `npm start`
|
||||
|
||||
Runs the app in the development mode.\
|
||||
Open [http://localhost:3000](http://localhost:3000) to view it in your browser.
|
||||
|
||||
The page will reload when you make changes.\
|
||||
You may also see any lint errors in the console.
|
||||
|
||||
### `npm test`
|
||||
|
||||
Launches the test runner in the interactive watch mode.\
|
||||
See the section about [running tests](https://facebook.github.io/create-react-app/docs/running-tests) for more information.
|
||||
|
||||
### `npm run build`
|
||||
|
||||
Builds the app for production to the `build` folder.\
|
||||
It correctly bundles React in production mode and optimizes the build for the best performance.
|
||||
|
||||
The build is minified and the filenames include the hashes.\
|
||||
Your app is ready to be deployed!
|
||||
|
||||
See the section about [deployment](https://facebook.github.io/create-react-app/docs/deployment) for more information.
|
||||
|
||||
### `npm run eject`
|
||||
|
||||
**Note: this is a one-way operation. Once you `eject`, you can't go back!**
|
||||
|
||||
If you aren't satisfied with the build tool and configuration choices, you can `eject` at any time. This command will remove the single build dependency from your project.
|
||||
|
||||
Instead, it will copy all the configuration files and the transitive dependencies (webpack, Babel, ESLint, etc) right into your project so you have full control over them. All of the commands except `eject` will still work, but they will point to the copied scripts so you can tweak them. At this point you're on your own.
|
||||
|
||||
You don't have to ever use `eject`. The curated feature set is suitable for small and middle deployments, and you shouldn't feel obligated to use this feature. However we understand that this tool wouldn't be useful if you couldn't customize it when you are ready for it.
|
||||
|
||||
## Learn More
|
||||
|
||||
You can learn more in the [Create React App documentation](https://facebook.github.io/create-react-app/docs/getting-started).
|
||||
|
||||
To learn React, check out the [React documentation](https://reactjs.org/).
|
||||
|
||||
### Code Splitting
|
||||
|
||||
This section has moved here: [https://facebook.github.io/create-react-app/docs/code-splitting](https://facebook.github.io/create-react-app/docs/code-splitting)
|
||||
|
||||
### Analyzing the Bundle Size
|
||||
|
||||
This section has moved here: [https://facebook.github.io/create-react-app/docs/analyzing-the-bundle-size](https://facebook.github.io/create-react-app/docs/analyzing-the-bundle-size)
|
||||
|
||||
### Making a Progressive Web App
|
||||
|
||||
This section has moved here: [https://facebook.github.io/create-react-app/docs/making-a-progressive-web-app](https://facebook.github.io/create-react-app/docs/making-a-progressive-web-app)
|
||||
|
||||
### Advanced Configuration
|
||||
|
||||
This section has moved here: [https://facebook.github.io/create-react-app/docs/advanced-configuration](https://facebook.github.io/create-react-app/docs/advanced-configuration)
|
||||
|
||||
### Deployment
|
||||
|
||||
This section has moved here: [https://facebook.github.io/create-react-app/docs/deployment](https://facebook.github.io/create-react-app/docs/deployment)
|
||||
|
||||
### `npm run build` fails to minify
|
||||
|
||||
This section has moved here: [https://facebook.github.io/create-react-app/docs/troubleshooting#npm-run-build-fails-to-minify](https://facebook.github.io/create-react-app/docs/troubleshooting#npm-run-build-fails-to-minify)
|
||||
@@ -1,40 +0,0 @@
|
||||
{
|
||||
"name": "client",
|
||||
"version": "0.1.0",
|
||||
"private": true,
|
||||
"dependencies": {
|
||||
"@testing-library/jest-dom": "^5.16.5",
|
||||
"@testing-library/react": "^13.4.0",
|
||||
"@testing-library/user-event": "^13.5.0",
|
||||
"axios": "^1.1.3",
|
||||
"react": "^18.2.0",
|
||||
"react-dom": "^18.2.0",
|
||||
"react-scripts": "5.0.1",
|
||||
"react-table": "^7.8.0",
|
||||
"web-vitals": "^2.1.4"
|
||||
},
|
||||
"scripts": {
|
||||
"start": "react-scripts start",
|
||||
"build": "react-scripts build",
|
||||
"test": "react-scripts test",
|
||||
"eject": "react-scripts eject"
|
||||
},
|
||||
"eslintConfig": {
|
||||
"extends": [
|
||||
"react-app",
|
||||
"react-app/jest"
|
||||
]
|
||||
},
|
||||
"browserslist": {
|
||||
"production": [
|
||||
">0.2%",
|
||||
"not dead",
|
||||
"not op_mini all"
|
||||
],
|
||||
"development": [
|
||||
"last 1 chrome version",
|
||||
"last 1 firefox version",
|
||||
"last 1 safari version"
|
||||
]
|
||||
}
|
||||
}
|
||||
Binary file not shown.
|
Before Width: | Height: | Size: 3.8 KiB |
@@ -1,43 +0,0 @@
|
||||
<!DOCTYPE html>
|
||||
<html lang="en">
|
||||
<head>
|
||||
<meta charset="utf-8" />
|
||||
<link rel="icon" href="%PUBLIC_URL%/favicon.ico" />
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1" />
|
||||
<meta name="theme-color" content="#000000" />
|
||||
<meta
|
||||
name="description"
|
||||
content="Web site created using create-react-app"
|
||||
/>
|
||||
<link rel="apple-touch-icon" href="%PUBLIC_URL%/logo192.png" />
|
||||
<!--
|
||||
manifest.json provides metadata used when your web app is installed on a
|
||||
user's mobile device or desktop. See https://developers.google.com/web/fundamentals/web-app-manifest/
|
||||
-->
|
||||
<link rel="manifest" href="%PUBLIC_URL%/manifest.json" />
|
||||
<!--
|
||||
Notice the use of %PUBLIC_URL% in the tags above.
|
||||
It will be replaced with the URL of the `public` folder during the build.
|
||||
Only files inside the `public` folder can be referenced from the HTML.
|
||||
|
||||
Unlike "/favicon.ico" or "favicon.ico", "%PUBLIC_URL%/favicon.ico" will
|
||||
work correctly both with client-side routing and a non-root public URL.
|
||||
Learn how to configure a non-root public URL by running `npm run build`.
|
||||
-->
|
||||
<title>React App</title>
|
||||
</head>
|
||||
<body>
|
||||
<noscript>You need to enable JavaScript to run this app.</noscript>
|
||||
<div id="root"></div>
|
||||
<!--
|
||||
This HTML file is a template.
|
||||
If you open it directly in the browser, you will see an empty page.
|
||||
|
||||
You can add webfonts, meta tags, or analytics to this file.
|
||||
The build step will place the bundled scripts into the <body> tag.
|
||||
|
||||
To begin the development, run `npm start` or `yarn start`.
|
||||
To create a production bundle, use `npm run build` or `yarn build`.
|
||||
-->
|
||||
</body>
|
||||
</html>
|
||||
Binary file not shown.
|
Before Width: | Height: | Size: 5.2 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 9.4 KiB |
@@ -1,25 +0,0 @@
|
||||
{
|
||||
"short_name": "React App",
|
||||
"name": "Create React App Sample",
|
||||
"icons": [
|
||||
{
|
||||
"src": "favicon.ico",
|
||||
"sizes": "64x64 32x32 24x24 16x16",
|
||||
"type": "image/x-icon"
|
||||
},
|
||||
{
|
||||
"src": "logo192.png",
|
||||
"type": "image/png",
|
||||
"sizes": "192x192"
|
||||
},
|
||||
{
|
||||
"src": "logo512.png",
|
||||
"type": "image/png",
|
||||
"sizes": "512x512"
|
||||
}
|
||||
],
|
||||
"start_url": ".",
|
||||
"display": "standalone",
|
||||
"theme_color": "#000000",
|
||||
"background_color": "#ffffff"
|
||||
}
|
||||
@@ -1,3 +0,0 @@
|
||||
# https://www.robotstxt.org/robotstxt.html
|
||||
User-agent: *
|
||||
Disallow:
|
||||
@@ -1,63 +0,0 @@
|
||||
table {
|
||||
border-spacing: 0;
|
||||
border: 1px solid #ededed;
|
||||
}
|
||||
table tr:last-child td {
|
||||
border-bottom: 0;
|
||||
}
|
||||
table th,
|
||||
table td {
|
||||
margin: 0;
|
||||
padding: 0.5rem;
|
||||
border-bottom: 1px solid #ededed;
|
||||
border-right: 1px solid #ededed;
|
||||
position: relative;
|
||||
}
|
||||
table th:last-child,
|
||||
table td:last-child {
|
||||
border-right: 0;
|
||||
}
|
||||
table tr:nth-child(even) {
|
||||
background-color: #fafafa;
|
||||
}
|
||||
|
||||
table th::before {
|
||||
position: absolute;
|
||||
right: 15px;
|
||||
top: 16px;
|
||||
content: "";
|
||||
width: 0;
|
||||
height: 0;
|
||||
border-left: 5px solid transparent;
|
||||
border-right: 5px solid transparent;
|
||||
}
|
||||
table th.sort-asc::before {
|
||||
border-bottom: 5px solid #22543d;
|
||||
}
|
||||
table th.sort-desc::before {
|
||||
border-top: 5px solid #22543d;
|
||||
}
|
||||
|
||||
.App {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
padding: 20px;
|
||||
}
|
||||
.badge {
|
||||
background-color: #9ae6b4;
|
||||
color: #22543d;
|
||||
margin-right: 4px;
|
||||
padding: 4px 8px;
|
||||
border-radius: 12px;
|
||||
font-size: 12px;
|
||||
font-weight: bold;
|
||||
text-transform: uppercase;
|
||||
}
|
||||
input {
|
||||
padding: 10px;
|
||||
margin-bottom: 20px;
|
||||
font-size: 18px;
|
||||
border-radius: 5px;
|
||||
border: 1px solid #ddd;
|
||||
box-shadow: none;
|
||||
}
|
||||
@@ -1,185 +0,0 @@
|
||||
import React, { useMemo, useState, useEffect } from "react";
|
||||
import axios from "axios";
|
||||
import Table from "./Table";
|
||||
import './App.css';
|
||||
|
||||
const Children = ({ values }) => {
|
||||
return (
|
||||
<>
|
||||
{values.map((child, idx) => {
|
||||
return (
|
||||
<div className="image">
|
||||
<img
|
||||
src={child.avatar}
|
||||
alt="Profile"
|
||||
/>
|
||||
</div>
|
||||
);
|
||||
})}
|
||||
</>
|
||||
);
|
||||
};
|
||||
|
||||
const Avatar = ({ value }) => {
|
||||
return (
|
||||
<div className="image">
|
||||
<img
|
||||
src={value}
|
||||
alt="Profile"
|
||||
/>
|
||||
</div>
|
||||
);
|
||||
};
|
||||
|
||||
const uploadToServer = (file, onUploadProgress) => {
|
||||
let formData = new FormData();
|
||||
|
||||
formData.append("file", file);
|
||||
|
||||
return axios.post('http://localhost:8080/api/csv/upload', formData, {
|
||||
headers: {
|
||||
"Content-Type": "multipart/form-data",
|
||||
},
|
||||
onUploadProgress,
|
||||
});
|
||||
};
|
||||
|
||||
function App() {
|
||||
|
||||
const [data, setData] = useState([]);
|
||||
const [selectedFiles, setSelectedFiles] = useState(undefined);
|
||||
const [currentFile, setCurrentFile] = useState(undefined);
|
||||
const [progress, setProgress] = useState(0);
|
||||
const [message, setMessage] = useState("");
|
||||
|
||||
const columns = useMemo(
|
||||
() => [
|
||||
{
|
||||
Header: "Employee Details",
|
||||
columns: [
|
||||
{
|
||||
Header: "Avatar",
|
||||
accessor: "avatar",
|
||||
Cell: ({ cell: { value } }) => <Avatar value={value} />
|
||||
},
|
||||
{
|
||||
Header: "Name",
|
||||
accessor: "name"
|
||||
},
|
||||
{
|
||||
Header: "Email",
|
||||
accessor: "email"
|
||||
},
|
||||
{
|
||||
Header: "Username",
|
||||
accessor: "username"
|
||||
},
|
||||
{
|
||||
Header: "DOB",
|
||||
accessor: "dob"
|
||||
},
|
||||
{
|
||||
Header: "Company",
|
||||
accessor: "company"
|
||||
},
|
||||
{
|
||||
Header: "Address",
|
||||
accessor: "address"
|
||||
},
|
||||
{
|
||||
Header: "Location",
|
||||
accessor: "location"
|
||||
},
|
||||
{
|
||||
Header: "Salary",
|
||||
accessor: "salary"
|
||||
},
|
||||
{
|
||||
Header: "Role",
|
||||
accessor: "role"
|
||||
},
|
||||
{
|
||||
Header: "Direct Reportee",
|
||||
accessor: "children",
|
||||
Cell: ({ cell: { value } }) => <Children values={value} />
|
||||
}
|
||||
]
|
||||
}
|
||||
],
|
||||
[]
|
||||
);
|
||||
|
||||
useEffect(() => {
|
||||
(async () => {
|
||||
const result = await axios("http://localhost:8080/api/employees");
|
||||
setData(result.data);
|
||||
})();
|
||||
}, []);
|
||||
|
||||
const selectFile = (event) => {
|
||||
setSelectedFiles(event.target.files);
|
||||
};
|
||||
|
||||
const upload = () => {
|
||||
let currentFile = selectedFiles[0];
|
||||
|
||||
setProgress(0);
|
||||
setCurrentFile(currentFile);
|
||||
|
||||
uploadToServer(currentFile, (event) => {
|
||||
setProgress(Math.round((100 * event.loaded) / event.total));
|
||||
})
|
||||
.then(async (response) => {
|
||||
setMessage(response.data.message);
|
||||
const result = await axios("http://localhost:8080/api/employees");
|
||||
setData(result.data);
|
||||
})
|
||||
.catch(() => {
|
||||
setProgress(0);
|
||||
setMessage("Could not upload the file!");
|
||||
setCurrentFile(undefined);
|
||||
});
|
||||
|
||||
setSelectedFiles(undefined);
|
||||
};
|
||||
|
||||
return (
|
||||
<div className="App">
|
||||
<div>
|
||||
{currentFile && (
|
||||
<div className="progress">
|
||||
<div
|
||||
className="progress-bar progress-bar-info progress-bar-striped"
|
||||
role="progressbar"
|
||||
aria-valuenow={progress}
|
||||
aria-valuemin="0"
|
||||
aria-valuemax="100"
|
||||
style={{ width: progress + "%" }}
|
||||
>
|
||||
{progress}%
|
||||
</div>
|
||||
</div>
|
||||
)}
|
||||
|
||||
<label className="btn btn-default">
|
||||
<input type="file" onChange={selectFile} />
|
||||
</label>
|
||||
|
||||
<button
|
||||
className="btn btn-success"
|
||||
disabled={!selectedFiles}
|
||||
onClick={upload}
|
||||
>
|
||||
Upload
|
||||
</button>
|
||||
|
||||
<div className="alert alert-light" role="alert">
|
||||
{message}
|
||||
</div>
|
||||
</div>
|
||||
<Table columns={columns} data={data} />
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
export default App;
|
||||
@@ -1,8 +0,0 @@
|
||||
import { render, screen } from '@testing-library/react';
|
||||
import App from './App';
|
||||
|
||||
test('renders learn react link', () => {
|
||||
render(<App />);
|
||||
const linkElement = screen.getByText(/learn react/i);
|
||||
expect(linkElement).toBeInTheDocument();
|
||||
});
|
||||
@@ -1,75 +0,0 @@
|
||||
import React, { useState } from "react";
|
||||
import { useTable, useFilters, useSortBy } from "react-table";
|
||||
|
||||
export default function Table({ columns, data }) {
|
||||
const [filterInput, setFilterInput] = useState("");
|
||||
// Use the state and functions returned from useTable to build your UI
|
||||
const {
|
||||
getTableProps,
|
||||
getTableBodyProps,
|
||||
headerGroups,
|
||||
rows,
|
||||
prepareRow,
|
||||
setFilter
|
||||
} = useTable(
|
||||
{
|
||||
columns,
|
||||
data
|
||||
},
|
||||
useFilters,
|
||||
useSortBy
|
||||
);
|
||||
|
||||
const handleFilterChange = e => {
|
||||
const value = e.target.value || undefined;
|
||||
setFilter("name", value);
|
||||
setFilterInput(value);
|
||||
};
|
||||
|
||||
// Render the UI for your table
|
||||
return (
|
||||
<>
|
||||
<input
|
||||
value={filterInput}
|
||||
onChange={handleFilterChange}
|
||||
placeholder={"Search name"}
|
||||
/>
|
||||
<table {...getTableProps()}>
|
||||
<thead>
|
||||
{headerGroups.map(headerGroup => (
|
||||
<tr {...headerGroup.getHeaderGroupProps()}>
|
||||
{headerGroup.headers.map(column => (
|
||||
<th
|
||||
{...column.getHeaderProps(column.getSortByToggleProps())}
|
||||
className={
|
||||
column.isSorted
|
||||
? column.isSortedDesc
|
||||
? "sort-desc"
|
||||
: "sort-asc"
|
||||
: ""
|
||||
}
|
||||
>
|
||||
{column.render("Header")}
|
||||
</th>
|
||||
))}
|
||||
</tr>
|
||||
))}
|
||||
</thead>
|
||||
<tbody {...getTableBodyProps()}>
|
||||
{rows.map((row, i) => {
|
||||
prepareRow(row);
|
||||
return (
|
||||
<tr {...row.getRowProps()}>
|
||||
{row.cells.map(cell => {
|
||||
return (
|
||||
<td {...cell.getCellProps()}>{cell.render("Cell")}</td>
|
||||
);
|
||||
})}
|
||||
</tr>
|
||||
);
|
||||
})}
|
||||
</tbody>
|
||||
</table>
|
||||
</>
|
||||
);
|
||||
}
|
||||
@@ -1,13 +0,0 @@
|
||||
body {
|
||||
margin: 0;
|
||||
font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', 'Roboto', 'Oxygen',
|
||||
'Ubuntu', 'Cantarell', 'Fira Sans', 'Droid Sans', 'Helvetica Neue',
|
||||
sans-serif;
|
||||
-webkit-font-smoothing: antialiased;
|
||||
-moz-osx-font-smoothing: grayscale;
|
||||
}
|
||||
|
||||
code {
|
||||
font-family: source-code-pro, Menlo, Monaco, Consolas, 'Courier New',
|
||||
monospace;
|
||||
}
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user